firestore

Documentation

Index

• type Client
  • func New(ctx *model.Context, projectID string, databaseID string) (*Client, error)
  • func (x *Client) Close() error
  • func (x *Client) GetAttrs(ctx *model.Context, ns types.Namespace) (model.Attributes, error)
  • func (x *Client) GetWorkflow(ctx *model.Context, id types.WorkflowID) (*model.WorkflowRecord, error)
  • func (x *Client) GetWorkflows(ctx *model.Context, offset, limit int) ([]model.WorkflowRecord, error)
  • func (x *Client) Lock(ctx *model.Context, ns types.Namespace, timeout time.Time) error
  • func (x *Client) PutAttrs(ctx *model.Context, ns types.Namespace, attrs model.Attributes) error
  • func (x *Client) PutWorkflow(ctx *model.Context, workflow model.WorkflowRecord) error
  • func (x *Client) Unlock(ctx *model.Context, ns types.Namespace) error

Types

type Client

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

func New

func New(ctx *model.Context, projectID string, databaseID string) (*Client, error)

func (*Client) Close

func (x *Client) Close() error

func (*Client) GetAttrs

func (x *Client) GetAttrs(ctx *model.Context, ns types.Namespace) (model.Attributes, error)

GetAttrs implements interfaces.Database.

func (*Client) GetWorkflow

func (x *Client) GetWorkflow(ctx *model.Context, id types.WorkflowID) (*model.WorkflowRecord, error)

func (*Client) GetWorkflows

func (x *Client) GetWorkflows(ctx *model.Context, offset, limit int) ([]model.WorkflowRecord, error)

func (*Client) Lock

func (x *Client) Lock(ctx *model.Context, ns types.Namespace, timeout time.Time) error

Lock implements interfaces.Database.

func (*Client) PutAttrs

func (x *Client) PutAttrs(ctx *model.Context, ns types.Namespace, attrs model.Attributes) error

PutAttrs implements interfaces.Database.

func (*Client) PutWorkflow

func (x *Client) PutWorkflow(ctx *model.Context, workflow model.WorkflowRecord) error

func (*Client) Unlock

func (x *Client) Unlock(ctx *model.Context, ns types.Namespace) error

Unlock implements interfaces.Database.