firestore

Documentation

Index

• type Client
  • func New(ctx context.Context, projectID string, databaseID string) (*Client, error)
  • func (x *Client) Close() error
  • func (x *Client) GetOrCreateState(ctx context.Context, msgType types.MsgType, input *model.State) (*model.State, bool, error)
  • func (x *Client) GetState(ctx context.Context, msgType types.MsgType, id string) (*model.State, error)
  • func (x *Client) UpdateState(ctx context.Context, msgType types.MsgType, id string, state types.MsgState, ...) error

Types

type Client

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

func New

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

func (*Client) Close

func (x *Client) Close() error

func (*Client) GetOrCreateState

func (x *Client) GetOrCreateState(ctx context.Context, msgType types.MsgType, input *model.State) (*model.State, bool, error)

GetOrCreateState returns the state of message processing. If the state is not found, it creates a new state and returns it. If the state is already acquired, it returns the state.

func (*Client) GetState

func (x *Client) GetState(ctx context.Context, msgType types.MsgType, id string) (*model.State, error)

GetState returns the state of message processing.

func (*Client) UpdateState

func (x *Client) UpdateState(ctx context.Context, msgType types.MsgType, id string, state types.MsgState, now time.Time) error

UpdateState updates the state of message processing.