inboxclient

Documentation

Index

• Constants
• Variables
• type InboxClient
  • func New() InboxClient
• type MessageReceiver

Constants

const CName = "common.inboxclient"

Variables

var (
	ErrPubKeyMissing     = errors.New("peer pub key missing")
	ErrNetworkMismatched = errors.New("network mismatched")
)

Types

type InboxClient

type InboxClient interface {
	InboxFetch(ctx context.Context, offset string) (messages []*coordinatorproto.InboxMessage, hasMore bool, err error)
	InboxAddMessage(ctx context.Context, receiverPubKey crypto.PubKey, message *coordinatorproto.InboxMessage) (err error)
	SetMessageReceiver(receiver MessageReceiver) (err error)
	app.ComponentRunnable
}

func New

func New() InboxClient

type MessageReceiver

type MessageReceiver func(message *coordinatorproto.NotifySubscribeEvent)