privatemessaging

Documentation

Index

• type GroupManager
• type Manager
  • func NewPrivateMessaging(ctx context.Context, di database.Plugin, ii identity.Plugin, ...) (Manager, error)

Types

type GroupManager

type GroupManager interface {
	GetGroupByID(ctx context.Context, id string) (*fftypes.Group, error)
	GetGroups(ctx context.Context, filter database.AndFilter) ([]*fftypes.Group, *database.FilterResult, error)
	ResolveInitGroup(ctx context.Context, msg *fftypes.Message) (*fftypes.Group, error)
	EnsureLocalGroup(ctx context.Context, group *fftypes.Group) (ok bool, err error)
}

type Manager

type Manager interface {
	GroupManager

	Start() error
	SendMessage(ctx context.Context, ns string, in *fftypes.MessageInOut, waitConfirm bool) (out *fftypes.Message, err error)
	SendMessageWithID(ctx context.Context, ns string, id *fftypes.UUID, unresolved *fftypes.MessageInOut, resolved *fftypes.Message, waitConfirm bool) (out *fftypes.Message, err error)
	RequestReply(ctx context.Context, ns string, request *fftypes.MessageInOut) (reply *fftypes.MessageInOut, err error)
}

func NewPrivateMessaging

func NewPrivateMessaging(ctx context.Context, di database.Plugin, ii identity.Plugin, dx dataexchange.Plugin, bi blockchain.Plugin, ba batch.Manager, dm data.Manager, sa syncasync.Bridge, bp batchpin.Submitter) (Manager, error)