sync

package

v0.0.0-...-ac5d97d Latest Latest Go to latest Published: Apr 3, 2025 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func Marshal[T any](key string, input T) (output map[string]any, b []byte, err error)

func Unmarshal[T any](key string, input map[string]any) (output *T, err error)

type Receiver[T any] func([]*T)

type Stream string

const (
	StreamExchange    Stream = "SYNC:EXCHANGE"
	StreamBatteryFlow Stream = "SYNC:BATTERYFLOW"
)

func (s Stream) String() string

type Sync[T any] struct {
	// contains filtered or unexported fields
}

func New[T any](client *redis.Client, e adapter.Environment, stream Stream, reader Receiver[T]) *Sync[T]

func (s *Sync[T]) Push(data any)

func (s *Sync[T]) Run()