storebus

package module

v0.0.0-...-11e806d Latest Latest Go to latest Published: Mar 5, 2026 License: Apache-2.0 Imports: 9 Imported by: 2

Details

This section is empty.

This section is empty.

func UpdateHash(obj any) error

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

func NewStoreBus(dbname string) (*StoreBus, error)

func (sb *StoreBus) Close()

func (sb *StoreBus) CloseListStream(t string, c <-chan []any)

func (sb *StoreBus) CloseReadStream(t, id string, c <-chan any)

func (sb *StoreBus) Delete(ctx context.Context, t, id string) error

func (sb *StoreBus) List(ctx context.Context, t string, factory func() any) ([]any, error)

func (sb *StoreBus) ListStream(ctx context.Context, t string, factory func() any) (<-chan []any, error)

func (sb *StoreBus) Read(ctx context.Context, t, id string, factory func() any) (any, error)

func (sb *StoreBus) ReadStream(ctx context.Context, t, id string, factory func() any) (<-chan any, error)

func (sb *StoreBus) Write(ctx context.Context, t string, obj any) error