store

Documentation

Index

• type HashMapJoinStorage
  • func (s *HashMapJoinStorage[K]) JoinValue(key K, index int, value interface{}, f JoinValueFunc)
  • func (s *HashMapJoinStorage[K]) Start(ctx context.Context) error
  • func (s *HashMapJoinStorage[K]) Stop(ctx context.Context)
• type Item
• type JoinStorage
  • func MakeHashMapJoinStorage[K comparable](env environment.ServiceEnvironment, cfg JoinStorageConfig) JoinStorage[K]
  • func MakeJoinStorage[K comparable](storageType api.JoinStorageType, env environment.ServiceEnvironment, ...) JoinStorage[K]
• type JoinStorageConfig
• type JoinValueFunc
• type Storage

Types

type HashMapJoinStorage

type HashMapJoinStorage[K comparable] struct {
	// contains filtered or unexported fields
}

func (*HashMapJoinStorage[K]) JoinValue

func (s *HashMapJoinStorage[K]) JoinValue(key K, index int, value interface{}, f JoinValueFunc)

func (*HashMapJoinStorage[K]) Start

func (s *HashMapJoinStorage[K]) Start(ctx context.Context) error

func (*HashMapJoinStorage[K]) Stop

func (s *HashMapJoinStorage[K]) Stop(ctx context.Context)

type Item

type Item struct {
	// contains filtered or unexported fields
}

type JoinStorage

type JoinStorage[K comparable] interface {
	Storage
	JoinValue(key K, index int, value interface{}, f JoinValueFunc)
}

func MakeHashMapJoinStorage

func MakeHashMapJoinStorage[K comparable](env environment.ServiceEnvironment, cfg JoinStorageConfig) JoinStorage[K]

func MakeJoinStorage

func MakeJoinStorage[K comparable](storageType api.JoinStorageType,
	env environment.ServiceEnvironment,
	cfg JoinStorageConfig) JoinStorage[K]

type JoinStorageConfig

type JoinStorageConfig interface {
	GetTTL() time.Duration
	GetRenewTTL() bool
	GetName() string
}

type JoinValueFunc

type JoinValueFunc func(values [][]interface{}) bool

type Storage

type Storage interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context)
}