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](m metrics.Metrics, ttl time.Duration, renewTTL bool, streamName string) JoinStorage[K]
  • func MakeJoinStorage[K comparable](m metrics.Metrics, storageType api.JoinStorageType, ttl time.Duration, ...) JoinStorage[K]
• 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](m metrics.Metrics, ttl time.Duration, renewTTL bool, streamName string) JoinStorage[K]

func MakeJoinStorage

func MakeJoinStorage[K comparable](m metrics.Metrics, storageType api.JoinStorageType, ttl time.Duration, renewTTL bool, streamName string) JoinStorage[K]

type JoinValueFunc

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

type Storage

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