memory

package

v0.1.0 Latest Latest Go to latest Published: Jan 17, 2025 License: Apache-2.0 Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Buffer struct {
	Messages []schema.Message
	// contains filtered or unexported fields
}

func NewBufferMemory() *Buffer

func NewBufferWindowMemory(window int) *Buffer

func (c *Buffer) Clear(ctx context.Context) error

func (c *Buffer) Load(ctx context.Context, filter func(index, consumption int, message schema.Message) bool) []schema.Message

func (c *Buffer) LoadNext(ctx context.Context, filter func(message schema.Message) bool) *schema.Message

func (c *Buffer) Save(ctx context.Context, msg schema.Message) error

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

func NewDatabaseMemory(opts ...DatabaseOption) *Database

func (d *Database) Clear(_ context.Context) error

func (d *Database) Load(ctx context.Context, filter func(index, consumption int, message schema.Message) bool) []schema.Message

func (d *Database) LoadNext(ctx context.Context, filter func(message schema.Message) bool) *schema.Message

func (d *Database) Save(ctx context.Context, msg schema.Message) error

type DatabaseOption func(b *Database)

DatabaseOption is a function for creating new db storage with other default values.

func WithLoadFunc(fun func(ctx context.Context) []schema.Message) DatabaseOption

WithLoadFunc is an option for providing the save func.

func WithSaveFunc(fun func(ctx context.Context,
	msg *schema.Message) error) DatabaseOption

WithSaveFunc is an option for providing the save func.

func WithWindow(window int) DatabaseOption

WithWindow is an option for providing max item for user message buf.