memory

package

v1.1.0 Latest Latest Go to latest Published: Mar 1, 2024 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

func NewSource(config map[string]interface{}) source.Source

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

func (e *Memory) Has(ctx context.Context, key string) (bool, error)

func (e *Memory) Scan(ctx context.Context, key string, value interface{}) error

func (e *Memory) Watch(ctx context.Context, key string, callback func(event source.Event)) error