inmem

Documentation

Index

• type InMemory
  • func (mem *InMemory) Del(_ context.Context, id string) error
  • func (mem *InMemory) Get(_ context.Context, id string) (*timely.Schedule, error)
  • func (mem *InMemory) List(ctx context.Context, offset, count int) ([]timely.Schedule, error)
  • func (mem *InMemory) Put(_ context.Context, sc timely.Schedule, update bool) (*timely.Schedule, error)
  • func (mem *InMemory) Requests(ctx context.Context) (<-chan timely.Request, error)

Types

type InMemory

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

InMemory implements timely Scheduler using in-memory primitives. This implementation can be used for simple single-node use-cases.

func (*InMemory) Del

func (mem *InMemory) Del(_ context.Context, id string) error

func (*InMemory) Get

func (mem *InMemory) Get(_ context.Context, id string) (*timely.Schedule, error)

func (*InMemory) List

func (mem *InMemory) List(ctx context.Context, offset, count int) ([]timely.Schedule, error)

func (*InMemory) Put

func (mem *InMemory) Put(_ context.Context, sc timely.Schedule, update bool) (*timely.Schedule, error)

func (*InMemory) Requests

func (mem *InMemory) Requests(ctx context.Context) (<-chan timely.Request, error)