Documentation ¶
Index ¶
- Variables
- type Messenger
- type MixinConfiguration
- type MixinMessenger
- func (mm *MixinMessenger) OnAckReceipt(ctx context.Context, msg *mixin.MessageView, userId string) error
- func (mm *MixinMessenger) OnMessage(ctx context.Context, msg *mixin.MessageView, userId string) error
- func (mm *MixinMessenger) ReceiveMessage(ctx context.Context) (string, []byte, error)
- func (mm *MixinMessenger) SendMessage(ctx context.Context, b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrorDone = newError("DONE")
)
Functions ¶
This section is empty.
Types ¶
type MixinConfiguration ¶
type MixinMessenger ¶
type MixinMessenger struct {
// contains filtered or unexported fields
}
func NewMixinMessenger ¶
func NewMixinMessenger(ctx context.Context, conf *MixinConfiguration) (*MixinMessenger, error)
func (*MixinMessenger) OnAckReceipt ¶
func (mm *MixinMessenger) OnAckReceipt(ctx context.Context, msg *mixin.MessageView, userId string) error
func (*MixinMessenger) OnMessage ¶
func (mm *MixinMessenger) OnMessage(ctx context.Context, msg *mixin.MessageView, userId string) error
func (*MixinMessenger) ReceiveMessage ¶
func (*MixinMessenger) SendMessage ¶
func (mm *MixinMessenger) SendMessage(ctx context.Context, b []byte) error
Click to show internal directories.
Click to hide internal directories.