firestore

package

v0.2.2 Latest Latest Go to latest Published: Jan 14, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

func (x *Client) Close() error

func (x *Client) GetAlert(ctx context.Context, id types.AlertID) (*model.Alert, error)

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

GetAttrs implements interfaces.Database.

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

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

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

Lock implements interfaces.Database.

func (x *Client) PutAlert(ctx context.Context, alert model.Alert) error

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

PutAttrs implements interfaces.Database.

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

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

Unlock implements interfaces.Database.