storage

Documentation

Index

• Constants
• type AdapterCache
• type AdapterLocker
• type AdapterQueue
• type ConsumerFunc
• type Messager
• type Option
  • func WithConsumerFunc(f ConsumerFunc) Option
  • func WithGroupID(groupID string) Option
  • func WithKafkaConfig(c *sarama.Config) Option
  • func WithMessage(message Messager) Option
  • func WithPartition(partition int) Option
  • func WithStrategy(f sarama.BalanceStrategy) Option
  • func WithTopic(topic string) Option
• type Options
  • func DefaultOptions() *Options
  • func SetOptions(opts ...Option) *Options

Constants

const (
	PrefixKey = "__host"
)

Types

type AdapterCache

type AdapterCache interface {
	Name() string
	String() string
	Initialize(*gorm.DB) error
	RemoveFromTag(ctx context.Context, tag string) error
	Get(ctx context.Context, key string) (string, error)
	Set(ctx context.Context, key string, val interface{}, expire time.Duration) error
	Del(ctx context.Context, key string) error
	HashGet(ctx context.Context, hk, key string) (string, error)
	HashDel(ctx context.Context, hk, key string) error
	Increase(ctx context.Context, key string) error
	Decrease(ctx context.Context, key string) error
	Expire(ctx context.Context, key string, dur time.Duration) error
}

type AdapterLocker

type AdapterLocker interface {
	String() string
	Lock(ctx context.Context, key string, ttl time.Duration, options *redislock.Options) (*redislock.Lock, error)
}

type AdapterQueue

type AdapterQueue interface {
	String() string
	Append(opts ...Option) error
	Register(opts ...Option)
	Run(context.Context)
	Shutdown()
}

type ConsumerFunc

type ConsumerFunc func(Messager) error

type Messager

type Messager interface {
	SetID(string)
	SetStream(string)
	SetValues(map[string]interface{})
	GetID() string
	GetStream() string
	GetValues() map[string]interface{}
	GetPrefix() string
	SetPrefix(string)
	SetErrorCount(count int)
	GetErrorCount() int
	SetContext(ctx context.Context)
	GetContext() context.Context
}

type Option

type Option func(*Options)

func WithConsumerFunc

func WithConsumerFunc(f ConsumerFunc) Option

func WithGroupID

func WithGroupID(groupID string) Option

func WithKafkaConfig

func WithKafkaConfig(c *sarama.Config) Option

func WithMessage

func WithMessage(message Messager) Option

func WithPartition

func WithPartition(partition int) Option

func WithStrategy

func WithStrategy(f sarama.BalanceStrategy) Option

func WithTopic

func WithTopic(topic string) Option

type Options

type Options struct {
	Topic                       string
	GroupID                     string
	F                           ConsumerFunc
	Message                     Messager
	Partition                   int
	PartitionAssignmentStrategy sarama.BalanceStrategy
	KafkaConfig                 *sarama.Config
}

func DefaultOptions

func DefaultOptions() *Options

func SetOptions

func SetOptions(opts ...Option) *Options