source

package

v0.0.0-...-195e12e Latest Latest Go to latest Published: Mar 30, 2020 License: MIT Imports: 17 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

gitee.com/qw_1215/glink

Links

Open Source Insights

Documentation ¶

Index ¶

type ChanSource
- func NewChanSource(in chan interface{}) *ChanSource
- func (cs *ChanSource) Out() <-chan interface{}
- func (cs *ChanSource) Via(_flow streams.Flow) streams.Flow
type ConnType
type FileSource
- func NewFileSource(fileName string) *FileSource
- func (fs *FileSource) Out() <-chan interface{}
- func (fs *FileSource) Via(_flow streams.Flow) streams.Flow
type MqttSource
- func NewMqttSource(config *MQTT.ClientOptions, topic string) (*MqttSource, error)
- func (ms *MqttSource) Out() <-chan interface{}
- func (ms *MqttSource) Via(_flow *flow.Map) streams.Flow
type NatsSource
- func NewNatsSource(addr string, topic string) (*NatsSource, error)
- func (ns *NatsSource) Out() <-chan interface{}
- func (ns *NatsSource) Via(_flow *flow.Map) streams.Flow
type NetSource
- func NewNetSource(connType ConnType, address string) (*NetSource, error)
- func (ns *NetSource) Out() <-chan interface{}
- func (ns *NetSource) Via(_flow streams.Flow) streams.Flow
type NsqSource
- func NewNsqSource(url string, topic string, channel string) (*NsqSource, error)
- func (rs *NsqSource) HandleMessage(msg *nsq.Message) error
- func (rs *NsqSource) Out() <-chan interface{}
- func (rs *NsqSource) Via(_flow streams.Flow) streams.Flow
type PgSource
- func NewPgSource(connStr string) (*PgSource, error)
- func (p *PgSource) Out() <-chan interface{}
- func (p *PgSource) Via(_flow *flow.Map) streams.Flow
type PulsarSource
- func NewPulsarSource(clientOptions *pulsar.ClientOptions, consumerOptions *pulsar.ConsumerOptions) (*PulsarSource, error)
- func (ps *PulsarSource) Out() <-chan interface{}
- func (ps *PulsarSource) Via(_flow *flow.Map) streams.Flow
type RedisSource
- func NewRedisSource(config *redis.Options, channel string) (*RedisSource, error)
- func (rs *RedisSource) Out() <-chan interface{}
- func (rs *RedisSource) Via(_flow streams.Flow) streams.Flow

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ChanSource ¶

type ChanSource struct {
	// contains filtered or unexported fields
}

ChanSource streams data from chan

func NewChanSource ¶

func NewChanSource(in chan interface{}) *ChanSource

NewChanSource returns new ChanSource instance

func (*ChanSource) Out ¶

func (cs *ChanSource) Out() <-chan interface{}

Out returns channel for sending data

func (*ChanSource) Via ¶

func (cs *ChanSource) Via(_flow streams.Flow) streams.Flow

Via streams data through given flow

type ConnType ¶

type ConnType string

ConnType connection type

const (
	// TCP connection type
	TCP ConnType = "tcp"
	// UDP connection type
	UDP ConnType = "udp"
)

type FileSource ¶

type FileSource struct {
	// contains filtered or unexported fields
}

FileSource streams data from file system

func NewFileSource ¶

func NewFileSource(fileName string) *FileSource

NewFileSource returns new FileSource instance

func (*FileSource) Out ¶

func (fs *FileSource) Out() <-chan interface{}

Out returns channel for sending data

func (*FileSource) Via ¶

func (fs *FileSource) Via(_flow streams.Flow) streams.Flow

Via streams data through given flow

type MqttSource ¶

type MqttSource struct {
	// contains filtered or unexported fields
}

func NewMqttSource ¶

func NewMqttSource(config *MQTT.ClientOptions, topic string) (*MqttSource, error)

获取新的mqtt源

func (*MqttSource) Out ¶

func (ms *MqttSource) Out() <-chan interface{}

Out returns channel for sending data

func (*MqttSource) Via ¶

func (ms *MqttSource) Via(_flow *flow.Map) streams.Flow

Via streams data through given flow

type NatsSource ¶

type NatsSource struct {
	// contains filtered or unexported fields
}

func NewNatsSource ¶

func NewNatsSource(addr string, topic string) (*NatsSource, error)

func (*NatsSource) Out ¶

func (ns *NatsSource) Out() <-chan interface{}

Out returns channel for sending data

func (*NatsSource) Via ¶

func (ns *NatsSource) Via(_flow *flow.Map) streams.Flow

Via streams data through given flow

type NetSource ¶

type NetSource struct {
	// contains filtered or unexported fields
}

NetSource network socket connector

func NewNetSource ¶

func NewNetSource(connType ConnType, address string) (*NetSource, error)

NewNetSource creates a new NetSource

func (*NetSource) Out ¶

func (ns *NetSource) Out() <-chan interface{}

Out returns channel for sending data

func (*NetSource) Via ¶

func (ns *NetSource) Via(_flow streams.Flow) streams.Flow

Via streams data through given flow

type NsqSource ¶

type NsqSource struct {
	// contains filtered or unexported fields
}

func NewNsqSource ¶

func NewNsqSource(url string, topic string, channel string) (*NsqSource, error)

func (*NsqSource) HandleMessage ¶

func (rs *NsqSource) HandleMessage(msg *nsq.Message) error

处理消息

func (*NsqSource) Out ¶

func (rs *NsqSource) Out() <-chan interface{}

Out returns channel for sending data

func (*NsqSource) Via ¶

func (rs *NsqSource) Via(_flow streams.Flow) streams.Flow

Via streams data through given flow

type PgSource ¶

type PgSource struct {
	// contains filtered or unexported fields
}

func NewPgSource ¶

func NewPgSource(connStr string) (*PgSource, error)

func (*PgSource) Out ¶

func (p *PgSource) Out() <-chan interface{}

Out returns channel for sending data

func (*PgSource) Via ¶

func (p *PgSource) Via(_flow *flow.Map) streams.Flow

Via streams data through given flow

type PulsarSource ¶

type PulsarSource struct {
	// contains filtered or unexported fields
}

PulsarSource connector

func NewPulsarSource ¶

func NewPulsarSource(clientOptions *pulsar.ClientOptions, consumerOptions *pulsar.ConsumerOptions) (*PulsarSource, error)

NewPulsarSource creates a new PulsarSource

func (*PulsarSource) Out ¶

func (ps *PulsarSource) Out() <-chan interface{}

Out returns channel for sending data

func (*PulsarSource) Via ¶

func (ps *PulsarSource) Via(_flow *flow.Map) streams.Flow

Via streams data through given flow

type RedisSource ¶

type RedisSource struct {
	// contains filtered or unexported fields
}

RedisSource implements Redis Pub/Sub Source

func NewRedisSource ¶

func NewRedisSource(config *redis.Options, channel string) (*RedisSource, error)

NewRedisSource returns new RedisSource instance

func (*RedisSource) Out ¶

func (rs *RedisSource) Out() <-chan interface{}

Out returns channel for sending data

func (*RedisSource) Via ¶

func (rs *RedisSource) Via(_flow streams.Flow) streams.Flow

Via streams data through given flow

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL