gossiper_service

Documentation

Index

• Variables
• type Destination
  • func NewDestination(name string, args ...interface{}) (Destination, error)
  • func NewFlowDestination(args ...interface{}) (Destination, error)
• type DestinationFactory
• type FlowDestination
  • func (d *FlowDestination) Close() error
  • func (d *FlowDestination) Push(data interface{}) error
• type FlowDestinationOption
• type GossiperService
  • func (s *GossiperService) InitModuleService(m *component.Module) error
• type RedisStreamSource
  • func (s *RedisStreamSource) Close() error
  • func (s *RedisStreamSource) Pull() (map[string]interface{}, error)
• type RedisStreamSourceOption
• type Source
  • func NewRedisStreamSource(args ...interface{}) (Source, error)
  • func NewSource(name string, args ...interface{}) (Source, error)
• type SourceFactory

Variables

var (
	ErrUnsupportedSourceDriver      = errors.New("unsupported source driver")
	ErrUnsupportedDestinationDriver = errors.New("unsupported destination driver")
)

Types

type Destination

type Destination interface {
	Push(interface{}) error
	Close() error
}

func NewDestination

func NewDestination(name string, args ...interface{}) (Destination, error)

func NewFlowDestination

func NewFlowDestination(args ...interface{}) (Destination, error)

type DestinationFactory

type DestinationFactory func(...interface{}) (Destination, error)

type FlowDestination

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

func (*FlowDestination) Close

func (d *FlowDestination) Close() error

func (*FlowDestination) Push

func (d *FlowDestination) Push(data interface{}) error

type FlowDestinationOption

type FlowDestinationOption struct {
	FlowName string
}

type GossiperService

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

func (*GossiperService) InitModuleService

func (s *GossiperService) InitModuleService(m *component.Module) error

type RedisStreamSource

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

func (*RedisStreamSource) Close

func (s *RedisStreamSource) Close() error

func (*RedisStreamSource) Pull

func (s *RedisStreamSource) Pull() (map[string]interface{}, error)

type RedisStreamSourceOption

type RedisStreamSourceOption struct {
	Addr     string
	Db       int
	Password string
	Topic    string
	Nonce    string
}

type Source

type Source interface {
	Pull() (map[string]interface{}, error)
	Close() error
}

func NewRedisStreamSource

func NewRedisStreamSource(args ...interface{}) (Source, error)

func NewSource

func NewSource(name string, args ...interface{}) (Source, error)

type SourceFactory

type SourceFactory func(...interface{}) (Source, error)