interflow

Apr 27, 2024

Changes in this version

+ const Timeout

+ type AgentInterflow interface

+ OfflineNotify func() error

+ OnlineNotify func() error

+ Send func(ctx context.Context, msg *HookMsg) error

+ type Network string

+ const NetworkGRPC

+ const NetworkHTTP

+ func (n Network) IsGRPC() bool

+ func (n Network) IsHTTP() bool

+ func (n Network) String() string

+ type ServerInterflow interface

+ SendAgent func(ctx context.Context, to string, msg *HookMsg) error

+ ServerOfflineNotify func(agentUrls []string) error

+ ServerOnlineNotify func(agentUrls []string) error

Apr 17, 2024

Changes in this version

+ func GetReceiveInterflowCh() <-chan *HookMsg

+ func GetSendInterflowCh() chan<- *HookMsg

+ type Callback func(topic consts.TopicType, key, value []byte) error

+ type HookMsg struct

+ Key []byte

+ Topic string

+ Value []byte

+ func (l *HookMsg) Bytes() []byte

+ type Interflow interface

+ Close func() error

+ Receive func() error

+ Send func(ctx context.Context, to string, msg *HookMsg) error

+ SetHandles func(handles map[consts.TopicType]Callback) error

+ func NewHookInterflow(log *log.Helper) Interflow

+ func NewKafkaInterflow(kafkaMQServer *servers.KafkaMQServer, log *log.Helper) (Interflow, error)