broker

Aug 13, 2020

Changes in this version

+ type Broker struct

+ Metadata MetadataService

+ Preservation PreservationService

+ func New(logger logrus.FieldLogger, validator message.Validator, ...) *Broker

+ func (b *Broker) Request(_ context.Context, msg *message.Message) error

+ func (b *Broker) RequestResponse(context.Context, *message.Message) (*message.Message, error)

+ func (b *Broker) Run()

+ func (b *Broker) Stop()

+ func (s *Broker) Subscribe(t message.MessageTypeEnum, h MessageHandler)

+ type MessageHandler func(msg *message.Message) error

+ type MetadataService interface

+ Create func(context.Context, *message.MetadataCreateRequest) error

+ Delete func(context.Context, *message.MetadataDeleteRequest) error

+ Read func(context.Context, *message.MetadataReadRequest) (*message.MetadataReadResponse, error)

+ Update func(context.Context, *message.MetadataUpdateRequest) error

+ type MetadataServiceOp struct

+ func (s *MetadataServiceOp) Create(ctx context.Context, req *message.MetadataCreateRequest) error

+ func (s *MetadataServiceOp) Delete(ctx context.Context, req *message.MetadataDeleteRequest) error

+ func (s *MetadataServiceOp) Read(ctx context.Context, req *message.MetadataReadRequest) (*message.MetadataReadResponse, error)

+ func (s *MetadataServiceOp) Update(ctx context.Context, req *message.MetadataUpdateRequest) error

+ type PreservationService interface

+ Event func(context.Context, *message.PreservationEventRequest) error

+ type PreservationServiceOp struct

+ func (s *PreservationServiceOp) Event(ctx context.Context, req *message.PreservationEventRequest) error