foundation

type CacheAccessor interface {
	Set(key, value string, expiresIn int) error
	Get(key string) (string, error)
	Delete(key string) error
	IncrBy(key string, value int64) (result int64, err error)
	Exists(key string) (bool, error)
}

type Event interface {
	Marshal() []byte
	Topic() string
}

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

type EventInspector interface {
	RequeueEvent(ctx context.Context, targetType string, durationSec int64) error
	EventAck(ctx context.Context, e Event) error
}

type EventManager interface {
	Publish(ctx context.Context, topic string, event Event, opts ...EventPublishOption) error
	Subscribe(ctx context.Context, group, topic string, handler EventHandler) error
	ProducerErrors() <-chan error
	ConsumerErrors() <-chan error
	Close() error
}

type EventOptions interface {
	Partition() int32
	SetPartition(partition int32)
}

type EventPublishOption func(options EventOptions)

type Message interface {
	Send(context.Context, *MessageTemplate) error
}

type MessageTemplate struct {
	To            string                 `json:"to"`
	SignName      string                 `json:"sign_name"`
	TemplateCode  string                 `json:"template_name"`
	TemplateParam map[string]interface{} `json:"template_param"`
}

type Storage interface {
	Name() string
	Save(ctx context.Context, fileID string, reader io.Reader) error
	Fetch(ctx context.Context, fileID string, writer io.Writer) error
	Del(ctx context.Context, fileID string) error
	URL(ctx context.Context, fileID string) (*url.URL, error)
}