foundation

Apr 17, 2021

Changes in this version

+ type Message interface

+ Send func(context.Context, *MessageTemplate) error

+ type MessageTemplate struct

+ SignName string

+ TemplateCode string

+ TemplateParam map[string]interface{}

+ To string

Oct 22, 2020

Changes in this version

+ type CacheAccessor interface

+ Delete func(key string) error

+ Exists func(key string) (bool, error)

+ Get func(key string) (string, error)

+ IncrBy func(key string, value int64) (result int64, err error)

+ Set func(key, value string, expiresIn int) error

Jul 15, 2020

Changes in this version

+ type Event interface

+ Marshal func() []byte

+ Topic func() string

+ type EventHandler func(context.Context, ...[]byte) error

+ type EventInspector interface

+ EventAck func(ctx context.Context, e Event) error

+ RequeueEvent func(ctx context.Context, targetType string, durationSec int64) error

+ type EventManager interface

+ Close func() error

+ ConsumerErrors func() <-chan error

+ ProducerErrors func() <-chan error

+ Publish func(ctx context.Context, topic string, event Event, opts ...EventPublishOption) error

+ Subscribe func(ctx context.Context, group, topic string, handler EventHandler) error

+ type EventOptions interface

+ Partition func() int32

+ SetPartition func(partition int32)

+ type EventPublishOption func(options EventOptions)

+ type Storage interface

+ Del func(ctx context.Context, fileID string) error

+ Fetch func(ctx context.Context, fileID string, writer io.Writer) error

+ Name func() string

+ Save func(ctx context.Context, fileID string, reader io.Reader) error

+ URL func(ctx context.Context, fileID string) (*url.URL, error)