litterboxlocal

package
v0.13.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 24, 2022 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	AccountName string `envconfig:"ACCOUNT_NAME" default:"litterbox" json:"account_name"`
}

type LitterBox

type LitterBox struct {
	Config        Config
	Projects      projectsstore.Store
	Events        *events.Events
	EventSrcs     eventsrcsstore.Store
	PubSub        pubsub.PubSub
	ProgramsStore kvstore.Store
	L             L.Nullable
}

func (*LitterBox) EventSourceID

func (lb *LitterBox) EventSourceID() apieventsrc.EventSourceID

func (*LitterBox) Get added in v0.10.0

func (lb *LitterBox) Get(ctx context.Context, id litterbox.LitterBoxID) ([]byte, error)

func (*LitterBox) Loader

func (lb *LitterBox) Loader(ctx context.Context, path *apiprogram.Path) ([]byte, string, error)

func (*LitterBox) Run added in v0.10.0

func (lb *LitterBox) Run(
	ctx context.Context,
	id litterbox.LitterBoxID,
	ch chan<- *apievent.TrackIngestEventUpdate,
) (err error)

func (*LitterBox) RunEvent

func (lb *LitterBox) RunEvent(
	ctx context.Context,
	id litterbox.LitterBoxID,
	event *litterbox.LitterBoxEvent,
	ch chan<- *apievent.TrackIngestEventUpdate,
) (err error)

func (*LitterBox) Scoop

func (lb *LitterBox) Scoop(ctx context.Context, id litterbox.LitterBoxID) error

func (*LitterBox) Setup

func (lb *LitterBox) Setup(
	ctx context.Context,
	id litterbox.LitterBoxID,
	files []byte,
) (litterbox.LitterBoxID, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL