stategate

type Cache struct {

	// the item's business domain(ex: accounting)
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// entity key (unique within type)
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// the cached value's value to store
	Value *_struct.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// exp is the time at which the cached value will expire
	// if exp is 0, the value will never expire
	Exp *timestamp.Timestamp `protobuf:"bytes,4,opt,name=exp,proto3" json:"exp,omitempty"`
	// contains filtered or unexported fields
}

type CacheRef struct {

	// the cached value's business domain(ex: accounting)
	// must not be empty or contain spaces
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// cached value's key (unique within domain)
	// must not be empty or contain spaces
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type CacheServiceClient interface {
	// Set sets a value in the cache
	Set(ctx context.Context, in *Cache, opts ...grpc.CallOption) (*empty.Empty, error)
	// Get gets a value from the cache
	Get(ctx context.Context, in *CacheRef, opts ...grpc.CallOption) (*Cache, error)
	// Del deletes a value from the cache
	Del(ctx context.Context, in *CacheRef, opts ...grpc.CallOption) (*empty.Empty, error)
}

type CacheServiceServer interface {
	// Set sets a value in the cache
	Set(context.Context, *Cache) (*empty.Empty, error)
	// Get gets a value from the cache
	Get(context.Context, *CacheRef) (*Cache, error)
	// Del deletes a value from the cache
	Del(context.Context, *CacheRef) (*empty.Empty, error)
}

type Entities struct {
	Entities []*Entity `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	// contains filtered or unexported fields
}

type Entity struct {

	// the entity's business domain(ex: accounting)
	// must not be empty or contain spaces
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// the entity's type (ex: user)
	// must not be empty or contain spaces
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// the entity's key (unique within type).
	// must not be empty or contain spaces
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// the entity's values (k/v pairs)
	Values *_struct.Struct `protobuf:"bytes,4,opt,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type EntityRef struct {

	// the entity's business domain(ex: accounting)
	// must not be empty or contain spaces
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// entity type (ex: user)
	// must not be empty or contain spaces
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// entity key (unique within type)
	// must not be empty or contain spaces
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type EntityServiceClient interface {
	// Set sets the current state value of an entity, adds it to the event log, then broadcast the event to all interested consumers(EventService.Stream)
	Set(ctx context.Context, in *Entity, opts ...grpc.CallOption) (*empty.Empty, error)
	// Edit overwrites the k/v pairs present in the entity request without replacing the entire entity.
	// It then adds the state change to the event log, then broadcast the event to all interested consumers(EventService.Stream)
	// Edit returns the current state of the Entity after the mutation.
	Edit(ctx context.Context, in *Entity, opts ...grpc.CallOption) (*Entity, error)
	// Revert reverts an Entity to a previous version of itself by querying the event store.
	// Reverting an entity dispatches another event since it is a state change
	Revert(ctx context.Context, in *EventRef, opts ...grpc.CallOption) (*Entity, error)
	// Get gets an entity's current state
	Get(ctx context.Context, in *EntityRef, opts ...grpc.CallOption) (*Entity, error)
	// Del hard deletes an entity from current state store, adds it's state prior to deletion to the event log, then broadcast the event to all interested consumers(EventService.Stream)
	// an Entity may be recovered via querying the Event store for historical records of the deleted Entity.
	Del(ctx context.Context, in *EntityRef, opts ...grpc.CallOption) (*empty.Empty, error)
	// Search queries the current state of entities
	Search(ctx context.Context, in *SearchEntityOpts, opts ...grpc.CallOption) (*Entities, error)
}

type EntityServiceServer interface {
	// Set sets the current state value of an entity, adds it to the event log, then broadcast the event to all interested consumers(EventService.Stream)
	Set(context.Context, *Entity) (*empty.Empty, error)
	// Edit overwrites the k/v pairs present in the entity request without replacing the entire entity.
	// It then adds the state change to the event log, then broadcast the event to all interested consumers(EventService.Stream)
	// Edit returns the current state of the Entity after the mutation.
	Edit(context.Context, *Entity) (*Entity, error)
	// Revert reverts an Entity to a previous version of itself by querying the event store.
	// Reverting an entity dispatches another event since it is a state change
	Revert(context.Context, *EventRef) (*Entity, error)
	// Get gets an entity's current state
	Get(context.Context, *EntityRef) (*Entity, error)
	// Del hard deletes an entity from current state store, adds it's state prior to deletion to the event log, then broadcast the event to all interested consumers(EventService.Stream)
	// an Entity may be recovered via querying the Event store for historical records of the deleted Entity.
	Del(context.Context, *EntityRef) (*empty.Empty, error)
	// Search queries the current state of entities
	Search(context.Context, *SearchEntityOpts) (*Entities, error)
}

type Event struct {

	// identifies the event(uuid v4).
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// state of an Entity after it has been mutated
	Entity *Entity `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	// the invoked method that triggered the event
	Method string `protobuf:"bytes,5,opt,name=method,proto3" json:"method,omitempty"`
	// the authentication claims of the event producer.
	Claims *_struct.Struct `protobuf:"bytes,3,opt,name=claims,proto3" json:"claims,omitempty"`
	// timestamp(ns) of when the event was received.
	Time int64 `protobuf:"varint,4,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

type EventRef struct {

	// the event's entity's business domain(ex: accounting)
	// must not be empty or contain spaces
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// event entity type (ex: user)
	// must not be empty or contain spaces
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// event's entity's key (unique within type)
	// must not be empty or contain spaces
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// id is the event id.
	Id string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type EventServiceClient interface {
	// Stream creates an event stream/subscription to state changes to entities in real time. Glob matching is supported.
	Stream(ctx context.Context, in *StreamEventOpts, opts ...grpc.CallOption) (EventService_StreamClient, error)
	// Search queries historical events - every historical state change to an entity may be queried.
	Search(ctx context.Context, in *SearchEventOpts, opts ...grpc.CallOption) (*Events, error)
	// Get gets a single event
	Get(ctx context.Context, in *EventRef, opts ...grpc.CallOption) (*Event, error)
}

type EventServiceServer interface {
	// Stream creates an event stream/subscription to state changes to entities in real time. Glob matching is supported.
	Stream(*StreamEventOpts, EventService_StreamServer) error
	// Search queries historical events - every historical state change to an entity may be queried.
	Search(context.Context, *SearchEventOpts) (*Events, error)
	// Get gets a single event
	Get(context.Context, *EventRef) (*Event, error)
}

type EventService_StreamClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type EventService_StreamServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type Events struct {
	Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type Message struct {

	// the message's business domain(ex: accounting)
	// must not be empty or contain spaces
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// the message's channel(ex: general)
	// must not be empty or contain spaces
	Channel string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	// message's type (ex: comment)
	// must not be empty or contain spaces
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// the body of the message(k/v values).
	Body *_struct.Struct `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type Mutex struct {

	// the mutex's business domain(ex: accounting)
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// mutex key (unique within domain)
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// exp is the time at which the mutex value will expire
	// if exp is 0, the mutex will never expire
	Exp *timestamp.Timestamp `protobuf:"bytes,4,opt,name=exp,proto3" json:"exp,omitempty"`
	// contains filtered or unexported fields
}

type MutexRef struct {

	// the mutex's business domain(ex: accounting)
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// mutex key (unique within domain)
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type MutexServiceClient interface {
	// Lock locks a value for a period of time if it is not locked already.
	// If it is already locked, an error will be returned
	// It is best practice for client's to call Unlock when the distributed lock operation is completed instead of relying on the TTL
	Lock(ctx context.Context, in *Mutex, opts ...grpc.CallOption) (*empty.Empty, error)
	// Unlock unlocks the key(if it's currently locked) so that it may be locked again.
	// It is best practice for client's to call Unlock when the distributed lock operation is completed instead of relying on the TTL
	Unlock(ctx context.Context, in *MutexRef, opts ...grpc.CallOption) (*empty.Empty, error)
}

type MutexServiceServer interface {
	// Lock locks a value for a period of time if it is not locked already.
	// If it is already locked, an error will be returned
	// It is best practice for client's to call Unlock when the distributed lock operation is completed instead of relying on the TTL
	Lock(context.Context, *Mutex) (*empty.Empty, error)
	// Unlock unlocks the key(if it's currently locked) so that it may be locked again.
	// It is best practice for client's to call Unlock when the distributed lock operation is completed instead of relying on the TTL
	Unlock(context.Context, *MutexRef) (*empty.Empty, error)
}

type PeerMessage struct {

	// the unique id of the message
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// the message's business domain(ex: accounting)
	// must not be empty or contain spaces
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// the message's channel(ex: general)
	// must not be empty or contain spaces
	Channel string `protobuf:"bytes,3,opt,name=channel,proto3" json:"channel,omitempty"`
	// message's type (ex: comment)
	// must not be empty or contain spaces
	Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	// the body of the message(k/v values).
	Body *_struct.Struct `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	// the authentication claims of the message producer.
	Claims *_struct.Struct `protobuf:"bytes,6,opt,name=claims,proto3" json:"claims,omitempty"`
	// timestamp(ns) of when the message was broadcasted.
	Time int64 `protobuf:"varint,7,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

type PeerServiceClient interface {
	// Broadcast broadcasts a message to N subscribers(clients calling Stream)
	Broadcast(ctx context.Context, in *Message, opts ...grpc.CallOption) (*empty.Empty, error)
	// Stream consumes/streams messages from message producers(clients calling broadcast)
	Stream(ctx context.Context, in *StreamMessageOpts, opts ...grpc.CallOption) (PeerService_StreamClient, error)
}

type PeerServiceServer interface {
	// Broadcast broadcasts a message to N subscribers(clients calling Stream)
	Broadcast(context.Context, *Message) (*empty.Empty, error)
	// Stream consumes/streams messages from message producers(clients calling broadcast)
	Stream(*StreamMessageOpts, PeerService_StreamServer) error
}

type PeerService_StreamClient interface {
	Recv() (*PeerMessage, error)
	grpc.ClientStream
}

type PeerService_StreamServer interface {
	Send(*PeerMessage) error
	grpc.ServerStream
}

type SearchEntityOpts struct {

	// the entity's business domain(ex: accounting)
	// must not be empty or contain spaces
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// State type (ex: user)
	// must not be empty or contain spaces
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// json string to filter records that have values match k/v pairs ex: { "message": "hello world" }
	// please note that dot notation may be used to access nested fields
	QueryString string `protobuf:"bytes,3,opt,name=query_string,json=queryString,proto3" json:"query_string,omitempty"`
	// limit number of returned values
	Limit int32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// offset returned events(pagination)
	Offset int32 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	// sort sorts the returned entities by a specified field
	Sort *Sort `protobuf:"bytes,9,opt,name=sort,proto3" json:"sort,omitempty"`
	// contains filtered or unexported fields
}

type SearchEventOpts struct {

	// the entity's business domain(ex: accounting)
	// must not be empty or contain spaces
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// entity's type (ex: user)
	// must not be empty or contain spaces
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// json string to filter events based with values that match k/v pairs ex: { "entity.values.message": "hello world" }.
	// please note that dot notation may be used to access nested fields
	QueryString string `protobuf:"bytes,4,opt,name=query_string,json=queryString,proto3" json:"query_string,omitempty"`
	// only return events that occurred after specified min timestamp
	Min int64 `protobuf:"varint,5,opt,name=min,proto3" json:"min,omitempty"`
	// only return events that occurred before specified max timestamp
	Max int64 `protobuf:"varint,6,opt,name=max,proto3" json:"max,omitempty"`
	// limit number of returned values
	Limit int32 `protobuf:"varint,7,opt,name=limit,proto3" json:"limit,omitempty"`
	// offset returned events(pagination)
	Offset int32 `protobuf:"varint,8,opt,name=offset,proto3" json:"offset,omitempty"`
	// sort sorts the returned entities by a specified field
	Sort *Sort `protobuf:"bytes,9,opt,name=sort,proto3" json:"sort,omitempty"`
	// contains filtered or unexported fields
}

type Sort struct {

	// field is a field to sort the array by
	// please note that dot notation may be used to access nested fields
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// reverse reverses the direction of the sort
	Reverse bool `protobuf:"varint,2,opt,name=reverse,proto3" json:"reverse,omitempty"`
	// contains filtered or unexported fields
}

type StreamEventOpts struct {

	// the domain of the entity (ex: acme) that triggered the event
	// * indicates any domain
	// must not be empty or contain spaces
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// the type of the entity (ex: user) that triggered the event
	// * indicates any type
	// must not be empty or contain spaces
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type StreamMessageOpts struct {

	// the message's business domain(ex: accounting) to subscribe to
	// must not be empty or contain spaces
	// * indicates any domain
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	// the message's channel(ex: general) to subscribe to
	// must not be empty or contain spaces
	// * indicates any channel
	Channel string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	// message's type (ex: comment) to subscribe to
	// must not be empty or contain spaces
	// * indicates any type
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedCacheServiceServer struct {
}

type UnimplementedEntityServiceServer struct {
}

type UnimplementedEventServiceServer struct {
}

type UnimplementedMutexServiceServer struct {
}

type UnimplementedPeerServiceServer struct {
}