Documentation
¶
Index ¶
- func RunControlLoop(ctx context.Context, config bridgeconfig.Config) error
- func ShouldHandle(config bridgeconfig.Config, event protocol.Event) bool
- type MoltnetClient
- func (c *MoltnetClient) SendMessage(ctx context.Context, requestPayload protocol.SendMessageRequest) (protocol.MessageAccepted, error)
- func (c *MoltnetClient) StreamEvents(ctx context.Context, config bridgeconfig.Config, ...) error
- func (c *MoltnetClient) StreamEventsReady(ctx context.Context, config bridgeconfig.Config, onReady func(), ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunControlLoop ¶
func RunControlLoop(ctx context.Context, config bridgeconfig.Config) error
func ShouldHandle ¶
func ShouldHandle(config bridgeconfig.Config, event protocol.Event) bool
Types ¶
type MoltnetClient ¶
type MoltnetClient struct {
// contains filtered or unexported fields
}
func NewMoltnetClient ¶
func NewMoltnetClient(config bridgeconfig.Config) *MoltnetClient
func (*MoltnetClient) SendMessage ¶
func (c *MoltnetClient) SendMessage( ctx context.Context, requestPayload protocol.SendMessageRequest, ) (protocol.MessageAccepted, error)
func (*MoltnetClient) StreamEvents ¶
func (c *MoltnetClient) StreamEvents( ctx context.Context, config bridgeconfig.Config, handle func(event protocol.Event) error, ) error
func (*MoltnetClient) StreamEventsReady ¶
func (c *MoltnetClient) StreamEventsReady( ctx context.Context, config bridgeconfig.Config, onReady func(), handle func(event protocol.Event) error, ) error
Source Files
Click to show internal directories.
Click to hide internal directories.