firestore

Documentation

Index

• type FirestoreDB
  • func NewDB(ctx context.Context, project, app, instance string) (*FirestoreDB, error)
  • func (db *FirestoreDB) GetFlowExecution(ctx context.Context, id string) (*louhi.FlowExecution, error)
  • func (db *FirestoreDB) GetLatestFlowExecutions(ctx context.Context) (map[string]*louhi.FlowExecution, error)
  • func (db *FirestoreDB) PutFlowExecution(ctx context.Context, flow *louhi.FlowExecution) error

Types

type FirestoreDB

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

FirestoreDB is a louhi.DB implementation backed by Firestore.

func NewDB

func NewDB(ctx context.Context, project, app, instance string) (*FirestoreDB, error)

NewDB returns a louhi.DB implementation backed by Firestore.

func (*FirestoreDB) GetFlowExecution

func (db *FirestoreDB) GetFlowExecution(ctx context.Context, id string) (*louhi.FlowExecution, error)

GetFlowExecution implements DB.

func (*FirestoreDB) GetLatestFlowExecutions

func (db *FirestoreDB) GetLatestFlowExecutions(ctx context.Context) (map[string]*louhi.FlowExecution, error)

GetLatestFlowExecutions implements DB.

func (*FirestoreDB) PutFlowExecution

func (db *FirestoreDB) PutFlowExecution(ctx context.Context, flow *louhi.FlowExecution) error

PutFlowExecution implements DB.