adapter

Documentation

Index

• Variables
• func StrToBytes(s string) []byte
• type Adapter
  • func NewAdapter(a app.App) *Adapter
  • func (adapter *Adapter) Init() error
• type Packet
• type Source
  • func NewSource(adapter *Adapter, name string, sourceInfo *SourceInfo) *Source
  • func (source *Source) HandleRequest(request *Packet)
  • func (source *Source) Init() error
  • func (source *Source) InitSubscription() error
• type SourceConfig
• type SourceInfo
• type SourceManager
  • func NewSourceManager(adapter *Adapter) *SourceManager
  • func (sm *SourceManager) Initialize() error
  • func (sm *SourceManager) LoadSourceConfig(filename string) (*SourceConfig, error)

Variables

var DefaultWorkerCount int = 8

Default settings

Functions

func StrToBytes

func StrToBytes(s string) []byte

Types

type Adapter

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

func NewAdapter

func NewAdapter(a app.App) *Adapter

func (*Adapter) Init

func (adapter *Adapter) Init() error

type Packet

type Packet struct {
	EventName string
	Payload   []byte
	Offset    int64
}

type Source

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

func NewSource

func NewSource(adapter *Adapter, name string, sourceInfo *SourceInfo) *Source

func (*Source) HandleRequest

func (source *Source) HandleRequest(request *Packet)

func (*Source) Init

func (source *Source) Init() error

func (*Source) InitSubscription

func (source *Source) InitSubscription() error

type SourceConfig

type SourceConfig struct {
	Sources map[string]SourceInfo `json:"sources"`
}

type SourceInfo

type SourceInfo struct {
	Hosts       []string `json:"hosts"`
	Topic       string   `json:"topic"`
	GroupId     string   `json:"groupId"`
	WorkerCount *int     `json:"worker_count,omitempty"`
}

type SourceManager

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

func NewSourceManager

func NewSourceManager(adapter *Adapter) *SourceManager

func (*SourceManager) Initialize

func (sm *SourceManager) Initialize() error

func (*SourceManager) LoadSourceConfig

func (sm *SourceManager) LoadSourceConfig(filename string) (*SourceConfig, error)