update

Documentation

Index

• type Duplicate
• type Registry
• type RegistryImpl
  • func NewRegistry() *RegistryImpl
  • func (r *RegistryImpl) Add(request *updatepb.Request) (*Update, Duplicate, RemoveFunc)
  • func (r *RegistryImpl) Clear()
  • func (r *RegistryImpl) CreateOutgoingMessages(startedEventID int64) ([]*protocolpb.Message, error)
  • func (r *RegistryImpl) HasPending(filterMessages []*protocolpb.Message) bool
  • func (r *RegistryImpl) ProcessIncomingMessages(messages []*protocolpb.Message) error
• type RemoveFunc
• type Update
  • func (u *Update) WaitOutcome(ctx context.Context) (*updatepb.Outcome, error)

Types

type Duplicate

type Duplicate bool

type Registry

type Registry interface {
	Add(request *updatepb.Request) (*Update, Duplicate, RemoveFunc)

	CreateOutgoingMessages(startedEventID int64) ([]*protocolpb.Message, error)

	HasPending(filterMessages []*protocolpb.Message) bool
	ProcessIncomingMessages(messages []*protocolpb.Message) error

	Clear()
}

type RegistryImpl

type RegistryImpl struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRegistry

func NewRegistry() *RegistryImpl

func (*RegistryImpl) Add

func (r *RegistryImpl) Add(request *updatepb.Request) (*Update, Duplicate, RemoveFunc)

func (*RegistryImpl) Clear

func (r *RegistryImpl) Clear()

func (*RegistryImpl) CreateOutgoingMessages

func (r *RegistryImpl) CreateOutgoingMessages(startedEventID int64) ([]*protocolpb.Message, error)

func (*RegistryImpl) HasPending

func (r *RegistryImpl) HasPending(filterMessages []*protocolpb.Message) bool

func (*RegistryImpl) ProcessIncomingMessages

func (r *RegistryImpl) ProcessIncomingMessages(messages []*protocolpb.Message) error

type RemoveFunc

type RemoveFunc func()

type Update

type Update struct {
	// contains filtered or unexported fields
}

func (*Update) WaitOutcome

func (u *Update) WaitOutcome(ctx context.Context) (*updatepb.Outcome, error)