eventgate

type Event struct {

	// Identifies the event(uuid).
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// the unmodified
	Object *Object `protobuf:"bytes,2,opt,name=object,proto3" json:"object,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 EventGateServiceClient interface {
	// SetObject sets the current state value of an object, adds it to the event log, then broadcast the event to all interested consumers
	SetObject(ctx context.Context, in *Object, opts ...grpc.CallOption) (*empty.Empty, error)
	// GetObject gets an object's current state values
	GetObject(ctx context.Context, in *ObjectRef, opts ...grpc.CallOption) (*Object, error)
	// StreamEvents creates an event stream/subscription to a given object type until fn returns false OR the context cancels.
	// Event Consumers invoke this method.
	StreamEvents(ctx context.Context, in *StreamOpts, opts ...grpc.CallOption) (EventGateService_StreamEventsClient, error)
	// SearchEvents returns an array of immutable historical events for a given object.
	SearchEvents(ctx context.Context, in *SearchOpts, opts ...grpc.CallOption) (*Events, error)
}

type EventGateServiceServer interface {
	// SetObject sets the current state value of an object, adds it to the event log, then broadcast the event to all interested consumers
	SetObject(context.Context, *Object) (*empty.Empty, error)
	// GetObject gets an object's current state values
	GetObject(context.Context, *ObjectRef) (*Object, error)
	// StreamEvents creates an event stream/subscription to a given object type until fn returns false OR the context cancels.
	// Event Consumers invoke this method.
	StreamEvents(*StreamOpts, EventGateService_StreamEventsServer) error
	// SearchEvents returns an array of immutable historical events for a given object.
	SearchEvents(context.Context, *SearchOpts) (*Events, error)
}

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

type EventGateService_StreamEventsServer 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 Object struct {

	// Object type (ex: user)
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Object key (unique within type)
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// Object values (structured k/v pairs)
	Values *_struct.Struct `protobuf:"bytes,3,opt,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type ObjectRef struct {

	// Object type (ex: user)
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Object key (unique within type)
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type SearchOpts struct {

	// Object type (ex: user)
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Object key (unique within type)
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// only return events that occurred after specified min timestamp
	Min int64 `protobuf:"varint,3,opt,name=min,proto3" json:"min,omitempty"`
	// only return events that occurred before specified max timestamp
	Max int64 `protobuf:"varint,4,opt,name=max,proto3" json:"max,omitempty"`
	// limit returned events
	Limit int64 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	// offset returned events(pagination)
	Offset int64 `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

type StreamOpts struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedEventGateServiceServer struct {
}