stategate_client_go

Feb 28, 2021

Changes in this version

+ type CacheClient struct

+ func NewCacheClient(ctx context.Context, target string, opts ...Opt) (*CacheClient, error)

+ func (c *CacheClient) Close() error

+ func (m *CacheClient) Del(ctx context.Context, ref *stategate.CacheRef) error

+ func (m *CacheClient) Get(ctx context.Context, ref *stategate.CacheRef) (*stategate.Cache, error)

+ func (m *CacheClient) Set(ctx context.Context, value *stategate.Cache) error

type ClientSet

+ func (c *ClientSet) Cache() *CacheClient

+ func (c *ClientSet) Mutex() *MutexClient

+ type MutexClient struct

+ func NewMutexClient(ctx context.Context, target string, opts ...Opt) (*MutexClient, error)

+ func (c *MutexClient) Close() error

+ func (m *MutexClient) Lock(ctx context.Context, mutex *stategate.Mutex) error

+ func (m *MutexClient) Unlock(ctx context.Context, ref *stategate.MutexRef) error

Feb 26, 2021

Changes in this version

+ type ClientSet struct

+ func NewClientSet(ctx context.Context, target string, opts ...Opt) (*ClientSet, error)

+ func (c *ClientSet) Close() error

+ func (c *ClientSet) Entity() *EntityClient

+ func (c *ClientSet) Event() *EventClient

+ func (c *ClientSet) Peer() *PeerClient

+ type PeerClient struct

+ func NewPeerClient(ctx context.Context, target string, opts ...Opt) (*PeerClient, error)

+ func (c *PeerClient) Close() error

+ func (p PeerClient) Broadcast(ctx context.Context, in *stategate.Message) error

+ func (p PeerClient) Stream(ctx context.Context, in *stategate.StreamMessageOpts, ...) error

Feb 25, 2021

Changes in this version

type EventClient

+ func (c *EventClient) Get(ctx context.Context, in *stategate.EventRef) (*stategate.Event, error)

Feb 25, 2021

Changes in this version

type EntityClient

+ func (c *EntityClient) Revert(ctx context.Context, in *stategate.RevertOpts) (*stategate.Entity, error)

Feb 25, 2021

Changes in this version

type EntityClient

+ func (c *EntityClient) Edit(ctx context.Context, in *stategate.Entity) (*stategate.Entity, error)

Feb 24, 2021

Changes in this version

+ type EntityClient struct

+ func NewEntityClient(ctx context.Context, target string, opts ...Opt) (*EntityClient, error)

+ func (c *EntityClient) Close() error

+ func (c *EntityClient) Del(ctx context.Context, in *stategate.EntityRef) error

+ func (c *EntityClient) Get(ctx context.Context, in *stategate.EntityRef) (*stategate.Entity, error)

+ func (c *EntityClient) Search(ctx context.Context, in *stategate.SearchEntitiesOpts) (*stategate.Entities, error)

+ func (c *EntityClient) Set(ctx context.Context, in *stategate.Entity) error

Feb 19, 2021

Changes in this version

type StateClient

+ func (c *StateClient) Del(ctx context.Context, in *stategate.StateRef) error

Feb 19, 2021

Changes in this version

+ type StateClient struct

+ func NewStateClient(ctx context.Context, target string, opts ...Opt) (*StateClient, error)

+ func (c *StateClient) Close() error

+ func (c *StateClient) Get(ctx context.Context, in *stategate.StateRef) (*stategate.State, error)

+ func (c *StateClient) Search(ctx context.Context, in *stategate.SearchStateOpts) (*stategate.StateValues, error)

+ func (c *StateClient) Set(ctx context.Context, in *stategate.State) error

Feb 19, 2021

Changes in this version

+ type EventClient struct

+ func NewEventClient(ctx context.Context, target string, opts ...Opt) (*EventClient, error)

+ func (c *EventClient) Close() error

+ func (c *EventClient) Search(ctx context.Context, in *stategate.SearchEventOpts) (*stategate.Events, error)

+ func (c *EventClient) Stream(ctx context.Context, in *stategate.StreamOpts, ...) error

+ type ObjectClient struct

+ func NewObjectClient(ctx context.Context, target string, opts ...Opt) (*ObjectClient, error)

+ func (c *ObjectClient) Close() error

+ func (c *ObjectClient) Get(ctx context.Context, in *stategate.ObjectRef) (*stategate.Object, error)

+ func (c *ObjectClient) Search(ctx context.Context, in *stategate.SearchObjectOpts) (*stategate.Objects, error)

+ func (c *ObjectClient) Set(ctx context.Context, in *stategate.Object) error

Feb 11, 2021

Changes in this version

type Client

+ func (c *Client) SearchObjects(ctx context.Context, in *stategate.SearchObjectOpts) (*stategate.Objects, error)

Feb 11, 2021

Changes in this version

+ type Client struct

+ func NewClient(ctx context.Context, target string, opts ...Opt) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) GetObject(ctx context.Context, in *stategate.ObjectRef) error

+ func (c *Client) SearchEvents(ctx context.Context, in *stategate.SearchOpts) (*stategate.Events, error)

+ func (c *Client) SetObject(ctx context.Context, in *stategate.Object) error

+ func (c *Client) StreamEvents(ctx context.Context, in *stategate.StreamOpts, ...) error

+ type Opt func(o *Options)

+ func WithIDToken(idToken bool) Opt

+ func WithLogging(logging, logPayload bool) Opt

+ func WithMetrics(metrics bool) Opt

+ func WithTokenSource(tokenSource oauth2.TokenSource) Opt

+ func WithTransportCreds(creds credentials.TransportCredentials) Opt

+ type Options struct