privatemessaging

Documentation

Index

• type GroupManager
• type Manager
  • func NewPrivateMessaging(ctx context.Context, ns *core.Namespace, di database.Plugin, ...) (Manager, error)

Types

type GroupManager

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

type Manager

type Manager interface {
	core.Named
	GroupManager

	NewMessage(msg *core.MessageInOut) syncasync.Sender
	SendMessage(ctx context.Context, in *core.MessageInOut, waitConfirm bool) (out *core.Message, err error)
	RequestReply(ctx context.Context, request *core.MessageInOut) (reply *core.MessageInOut, err error)

	// From operations.OperationHandler
	PrepareOperation(ctx context.Context, op *core.Operation) (*core.PreparedOperation, error)
	RunOperation(ctx context.Context, op *core.PreparedOperation) (outputs fftypes.JSONObject, phase core.OpPhase, err error)
}

func NewPrivateMessaging

func NewPrivateMessaging(ctx context.Context, ns *core.Namespace, di database.Plugin, dx dataexchange.Plugin, bi blockchain.Plugin, im identity.Manager, ba batch.Manager, dm data.Manager, sa syncasync.Bridge, mult multiparty.Manager, mm metrics.Manager, om operations.Manager, cacheManager cache.Manager) (Manager, error)