foundation

README

foundation-go

go 相关工具包

Documentation

Index

• type CacheAccessor
• type Event
• type EventHandler
• type EventInspector
• type EventManager
• type EventOptions
• type EventPublishOption
• type Message
• type MessageTemplate
• type Storage

Types

type CacheAccessor

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)
}

CacheAccessor 缓存读取器

type Event

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

type EventHandler

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

type EventInspector

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

type EventManager

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

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

type EventPublishOption

type EventPublishOption func(options EventOptions)

type Message

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

type MessageTemplate

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

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)
}