events

Documentation

Index

• type Emitter
  • func NewEmitter(logger log.Logger, cfg *service.EventsConfig) (Emitter, error)
• type FileUploaded
  • func (f FileUploaded) Bytes() []byte
• type MockEmitter
  • func (*MockEmitter) FilesUploaded(shardKey string, fileIDs []string) error

Types

type Emitter

type Emitter interface {
	FilesUploaded(shardKey string, fileIDs []string) error
}

func NewEmitter

func NewEmitter(logger log.Logger, cfg *service.EventsConfig) (Emitter, error)

type FileUploaded

type FileUploaded struct {
	FileID     string    `json:"fileID"`
	ShardKey   string    `json:"shardKey"`
	UploadedAt time.Time `json:"uploadedAt"`
}

func (FileUploaded) Bytes

func (f FileUploaded) Bytes() []byte

type MockEmitter

type MockEmitter struct{}

func (*MockEmitter) FilesUploaded

func (*MockEmitter) FilesUploaded(shardKey string, fileIDs []string) error