apipb

package
v1.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 31, 2022 License: Apache-2.0 Imports: 21 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	Any = "*"
)

Variables

View Source 
var (
	Algorithm_name = map[int32]string{
		0: "BFS",
		1: "DFS",
	}
	Algorithm_value = map[string]int32{
		"BFS": 0,
		"DFS": 1,
	}
)

Enum value maps for Algorithm.

View Source 
var (
	Aggregate_name = map[int32]string{
		0: "COUNT",
		1: "SUM",
		2: "AVG",
		3: "MAX",
		4: "MIN",
		5: "PROD",
	}
	Aggregate_value = map[string]int32{
		"COUNT": 0,
		"SUM":   1,
		"AVG":   2,
		"MAX":   3,
		"MIN":   4,
		"PROD":  5,
	}
)

Enum value maps for Aggregate.

View Source 
var (
	Membership_name = map[int32]string{
		0: "UNKNOWN",
		1: "FOLLOWER",
		2: "CANDIDATE",
		3: "LEADER",
		4: "SHUTDOWN",
	}
	Membership_value = map[string]int32{
		"UNKNOWN":   0,
		"FOLLOWER":  1,
		"CANDIDATE": 2,
		"LEADER":    3,
		"SHUTDOWN":  4,
	}
)

Enum value maps for Membership.

View Source 
var File_graphik_proto protoreflect.FileDescriptor

Functions

func NewStruct 

func NewStruct(data map[string]interface{}) *structpb.Struct

func RegisterDatabaseServiceServer 

func RegisterDatabaseServiceServer(s *grpc.Server, srv DatabaseServiceServer)

func RegisterRaftServiceServer 

func RegisterRaftServiceServer(s *grpc.Server, srv RaftServiceServer)

Types

type AggFilter 

type AggFilter struct {
	Filter    *Filter   `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Aggregate Aggregate `protobuf:"varint,2,opt,name=aggregate,proto3,enum=api.Aggregate" json:"aggregate,omitempty"`
	Field     string    `protobuf:"bytes,3,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*AggFilter) Descriptor deprecated 

func (*AggFilter) Descriptor() ([]byte, []int)

Deprecated: Use AggFilter.ProtoReflect.Descriptor instead.

func (*AggFilter) GetAggregate 

func (x *AggFilter) GetAggregate() Aggregate

func (*AggFilter) GetField 

func (x *AggFilter) GetField() string

func (*AggFilter) GetFilter 

func (x *AggFilter) GetFilter() *Filter

func (*AggFilter) ProtoMessage 

func (*AggFilter) ProtoMessage()

func (*AggFilter) ProtoReflect 

func (x *AggFilter) ProtoReflect() protoreflect.Message

func (*AggFilter) Reset 

func (x *AggFilter) Reset()

func (*AggFilter) String 

func (x *AggFilter) String() string

func (*AggFilter) Validate 

func (this *AggFilter) Validate() error

type Aggregate 

type Aggregate int32
const (
	Aggregate_COUNT Aggregate = 0
	Aggregate_SUM   Aggregate = 1
	Aggregate_AVG   Aggregate = 2
	Aggregate_MAX   Aggregate = 3
	Aggregate_MIN   Aggregate = 4
	Aggregate_PROD  Aggregate = 5
)

func (Aggregate) Descriptor 

func (Aggregate) Descriptor() protoreflect.EnumDescriptor

func (Aggregate) Enum 

func (x Aggregate) Enum() *Aggregate

func (Aggregate) EnumDescriptor deprecated 

func (Aggregate) EnumDescriptor() ([]byte, []int)

Deprecated: Use Aggregate.Descriptor instead.

func (Aggregate) Number 

func (x Aggregate) Number() protoreflect.EnumNumber

func (Aggregate) String 

func (x Aggregate) String() string

func (Aggregate) Type 

func (Aggregate) Type() protoreflect.EnumType

type Algorithm 

type Algorithm int32
const (
	// BFS is short for the breadth-first search algorithm
	Algorithm_BFS Algorithm = 0
	// DFS is short for the depth-first search algorithm
	Algorithm_DFS Algorithm = 1
)

func (Algorithm) Descriptor 

func (Algorithm) Descriptor() protoreflect.EnumDescriptor

func (Algorithm) Enum 

func (x Algorithm) Enum() *Algorithm

func (Algorithm) EnumDescriptor deprecated 

func (Algorithm) EnumDescriptor() ([]byte, []int)

Deprecated: Use Algorithm.Descriptor instead.

func (Algorithm) Number 

func (x Algorithm) Number() protoreflect.EnumNumber

func (Algorithm) String 

func (x Algorithm) String() string

func (Algorithm) Type 

func (Algorithm) Type() protoreflect.EnumType

type AuthTarget 

type AuthTarget struct {

	// user is the user making the request
	User *Doc `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// target is the request/response represented as a Struct
	Target *_struct.Struct `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// headers are the request headers
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

AuthTarget is the payload/input to Authorizer expressions

func (*AuthTarget) AsMap 

func (n *AuthTarget) AsMap() map[string]interface{}

func (*AuthTarget) Descriptor deprecated 

func (*AuthTarget) Descriptor() ([]byte, []int)

Deprecated: Use AuthTarget.ProtoReflect.Descriptor instead.

func (*AuthTarget) GetHeaders 

func (x *AuthTarget) GetHeaders() map[string]string

func (*AuthTarget) GetTarget 

func (x *AuthTarget) GetTarget() *_struct.Struct

func (*AuthTarget) GetUser 

func (x *AuthTarget) GetUser() *Doc

func (*AuthTarget) ProtoMessage 

func (*AuthTarget) ProtoMessage()

func (*AuthTarget) ProtoReflect 

func (x *AuthTarget) ProtoReflect() protoreflect.Message

func (*AuthTarget) Reset 

func (x *AuthTarget) Reset()

func (*AuthTarget) String 

func (x *AuthTarget) String() string

func (*AuthTarget) Validate 

func (this *AuthTarget) Validate() error

type Authorizer 

type Authorizer struct {

	// name is the unique name of the authorizer
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// method is the rpc method that will invoke the authorizer
	Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	// expression is the boolean CEL expression that evaluates either the request or response body
	Expression string `protobuf:"bytes,3,opt,name=expression,proto3" json:"expression,omitempty"`
	// target_responses sets the authorizer to evaluate request bodies
	TargetRequests bool `protobuf:"varint,4,opt,name=target_requests,json=targetRequests,proto3" json:"target_requests,omitempty"`
	// target_responses sets the authorizer to evaluate response bodies
	TargetResponses bool `protobuf:"varint,5,opt,name=target_responses,json=targetResponses,proto3" json:"target_responses,omitempty"`
	// contains filtered or unexported fields
}

Authorizer is a graph primitive used for authorizing inbound requests and/or responses(see AuthTarget)

func (*Authorizer) Descriptor deprecated 

func (*Authorizer) Descriptor() ([]byte, []int)

Deprecated: Use Authorizer.ProtoReflect.Descriptor instead.

func (*Authorizer) GetExpression 

func (x *Authorizer) GetExpression() string

func (*Authorizer) GetMethod 

func (x *Authorizer) GetMethod() string

func (*Authorizer) GetName 

func (x *Authorizer) GetName() string

func (*Authorizer) GetTargetRequests 

func (x *Authorizer) GetTargetRequests() bool

func (*Authorizer) GetTargetResponses 

func (x *Authorizer) GetTargetResponses() bool

func (*Authorizer) ProtoMessage 

func (*Authorizer) ProtoMessage()

func (*Authorizer) ProtoReflect 

func (x *Authorizer) ProtoReflect() protoreflect.Message

func (*Authorizer) Reset 

func (x *Authorizer) Reset()

func (*Authorizer) String 

func (x *Authorizer) String() string

func (*Authorizer) Validate 

func (this *Authorizer) Validate() error

type Authorizers 

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

Authorizers is an array of authorizer

func (*Authorizers) Descriptor deprecated 

func (*Authorizers) Descriptor() ([]byte, []int)

Deprecated: Use Authorizers.ProtoReflect.Descriptor instead.

func (*Authorizers) GetAuthorizers 

func (x *Authorizers) GetAuthorizers() []*Authorizer

func (*Authorizers) ProtoMessage 

func (*Authorizers) ProtoMessage()

func (*Authorizers) ProtoReflect 

func (x *Authorizers) ProtoReflect() protoreflect.Message

func (*Authorizers) Reset 

func (x *Authorizers) Reset()

func (*Authorizers) String 

func (x *Authorizers) String() string

func (*Authorizers) Validate 

func (this *Authorizers) Validate() error

type Boolean 

type Boolean struct {
	Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Boolean is a simple boolean value

func (*Boolean) Descriptor deprecated 

func (*Boolean) Descriptor() ([]byte, []int)

Deprecated: Use Boolean.ProtoReflect.Descriptor instead.

func (*Boolean) GetValue 

func (x *Boolean) GetValue() bool

func (*Boolean) ProtoMessage 

func (*Boolean) ProtoMessage()

func (*Boolean) ProtoReflect 

func (x *Boolean) ProtoReflect() protoreflect.Message

func (*Boolean) Reset 

func (x *Boolean) Reset()

func (*Boolean) String 

func (x *Boolean) String() string

func (*Boolean) Validate 

func (this *Boolean) Validate() error

type ConnectFilter 

type ConnectFilter struct {

	// doc_ref is the ref to the target doc. (validator.field) = {msg_exists : true}]
	DocRef *Ref `protobuf:"bytes,1,opt,name=doc_ref,json=docRef,proto3" json:"doc_ref,omitempty"`
	// gtype is the type of connections to return. (validator.field) = {regex : "^.{1,225}$"}
	Gtype string `protobuf:"bytes,2,opt,name=gtype,proto3" json:"gtype,omitempty"`
	// expression is a CEL expression used to filter connections/modes
	Expression string `protobuf:"bytes,3,opt,name=expression,proto3" json:"expression,omitempty"`
	// limit is the maximum number of items to return. (validator.field) = {int_gt : 0}
	Limit uint64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// custom sorting of the results. (validator.field) = {regex : "((^|, )(|ref.gid|ref.gtype|^attributes.(.*)))+$"}
	Sort string `protobuf:"bytes,5,opt,name=sort,proto3" json:"sort,omitempty"`
	// seek to a specific key for pagination
	Seek string `protobuf:"bytes,6,opt,name=seek,proto3" json:"seek,omitempty"`
	// reverse the results
	Reverse bool `protobuf:"varint,7,opt,name=reverse,proto3" json:"reverse,omitempty"`
	// contains filtered or unexported fields
}

ConnectFilter is used to fetch connections related to a single noted

func (*ConnectFilter) AsMap 

func (n *ConnectFilter) AsMap() map[string]interface{}

func (*ConnectFilter) Descriptor deprecated 

func (*ConnectFilter) Descriptor() ([]byte, []int)

Deprecated: Use ConnectFilter.ProtoReflect.Descriptor instead.

func (*ConnectFilter) GetDocRef 

func (x *ConnectFilter) GetDocRef() *Ref

func (*ConnectFilter) GetExpression 

func (x *ConnectFilter) GetExpression() string

func (*ConnectFilter) GetGtype 

func (x *ConnectFilter) GetGtype() string

func (*ConnectFilter) GetLimit 

func (x *ConnectFilter) GetLimit() uint64

func (*ConnectFilter) GetReverse 

func (x *ConnectFilter) GetReverse() bool

func (*ConnectFilter) GetSeek 

func (x *ConnectFilter) GetSeek() string

func (*ConnectFilter) GetSort 

func (x *ConnectFilter) GetSort() string

func (*ConnectFilter) ProtoMessage 

func (*ConnectFilter) ProtoMessage()

func (*ConnectFilter) ProtoReflect 

func (x *ConnectFilter) ProtoReflect() protoreflect.Message

func (*ConnectFilter) Reset 

func (x *ConnectFilter) Reset()

func (*ConnectFilter) String 

func (x *ConnectFilter) String() string

func (*ConnectFilter) Validate 

func (this *ConnectFilter) Validate() error

type Connection 

type Connection struct {

	// ref is the ref to the connection
	Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// attributes are k/v pairs
	Attributes *_struct.Struct `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// directed is false if the connection is bi-directional
	Directed bool `protobuf:"varint,3,opt,name=directed,proto3" json:"directed,omitempty"`
	// from is the doc ref that is the source of the connection
	From *Ref `protobuf:"bytes,4,opt,name=from,proto3" json:"from,omitempty"`
	// to is the doc ref that is the destination of the connection
	To *Ref `protobuf:"bytes,5,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

Connection is a graph primitive that represents a relationship between two docs

func (*Connection) AsMap 

func (n *Connection) AsMap() map[string]interface{}

func (*Connection) Descriptor deprecated 

func (*Connection) Descriptor() ([]byte, []int)

Deprecated: Use Connection.ProtoReflect.Descriptor instead.

func (*Connection) GetAttributes 

func (x *Connection) GetAttributes() *_struct.Struct

func (*Connection) GetDirected 

func (x *Connection) GetDirected() bool

func (*Connection) GetFrom 

func (x *Connection) GetFrom() *Ref

func (*Connection) GetRef 

func (x *Connection) GetRef() *Ref

func (*Connection) GetTo 

func (x *Connection) GetTo() *Ref

func (*Connection) ProtoMessage 

func (*Connection) ProtoMessage()

func (*Connection) ProtoReflect 

func (x *Connection) ProtoReflect() protoreflect.Message

func (*Connection) Reset 

func (x *Connection) Reset()

func (*Connection) String 

func (x *Connection) String() string

func (*Connection) Validate 

func (this *Connection) Validate() error

type ConnectionConstructor 

type ConnectionConstructor struct {

	// ref is the ref to the new Connection. If an id isn't present, one will be generated.
	Ref *RefConstructor `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// attributes are k/v pairs
	Attributes *_struct.Struct `protobuf:"bytes,3,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// directed is false if the connection is bi-directional
	Directed bool `protobuf:"varint,4,opt,name=directed,proto3" json:"directed,omitempty"`
	// from is the doc ref that is the root of the connection
	From *Ref `protobuf:"bytes,5,opt,name=from,proto3" json:"from,omitempty"`
	// to is the doc ref that is the destination of the connection
	To *Ref `protobuf:"bytes,6,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

ConnectionConstructor is used to create an Connection

func (*ConnectionConstructor) AsMap 

func (e *ConnectionConstructor) AsMap() map[string]interface{}

func (*ConnectionConstructor) Descriptor deprecated 

func (*ConnectionConstructor) Descriptor() ([]byte, []int)

Deprecated: Use ConnectionConstructor.ProtoReflect.Descriptor instead.

func (*ConnectionConstructor) GetAttributes 

func (x *ConnectionConstructor) GetAttributes() *_struct.Struct

func (*ConnectionConstructor) GetDirected 

func (x *ConnectionConstructor) GetDirected() bool

func (*ConnectionConstructor) GetFrom 

func (x *ConnectionConstructor) GetFrom() *Ref

func (*ConnectionConstructor) GetRef 

func (x *ConnectionConstructor) GetRef() *RefConstructor

func (*ConnectionConstructor) GetTo 

func (x *ConnectionConstructor) GetTo() *Ref

func (*ConnectionConstructor) ProtoMessage 

func (*ConnectionConstructor) ProtoMessage()

func (*ConnectionConstructor) ProtoReflect 

func (x *ConnectionConstructor) ProtoReflect() protoreflect.Message

func (*ConnectionConstructor) Reset 

func (x *ConnectionConstructor) Reset()

func (*ConnectionConstructor) String 

func (x *ConnectionConstructor) String() string

func (*ConnectionConstructor) Validate 

func (this *ConnectionConstructor) Validate() error

type ConnectionConstructors 

type ConnectionConstructors struct {
	Connections []*ConnectionConstructor `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections,omitempty"`
	// contains filtered or unexported fields
}

ConnectionConstructors is an array of ConnectionConstructor

func (*ConnectionConstructors) Descriptor deprecated 

func (*ConnectionConstructors) Descriptor() ([]byte, []int)

Deprecated: Use ConnectionConstructors.ProtoReflect.Descriptor instead.

func (*ConnectionConstructors) GetConnections 

func (x *ConnectionConstructors) GetConnections() []*ConnectionConstructor

func (*ConnectionConstructors) ProtoMessage 

func (*ConnectionConstructors) ProtoMessage()

func (*ConnectionConstructors) ProtoReflect 

func (x *ConnectionConstructors) ProtoReflect() protoreflect.Message

func (*ConnectionConstructors) Reset 

func (x *ConnectionConstructors) Reset()

func (*ConnectionConstructors) String 

func (x *ConnectionConstructors) String() string

func (*ConnectionConstructors) Validate 

func (this *ConnectionConstructors) Validate() error

type Connections 

type Connections struct {
	Connections []*Connection `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections,omitempty"`
	SeekNext    string        `protobuf:"bytes,2,opt,name=seek_next,json=seekNext,proto3" json:"seek_next,omitempty"`
	// contains filtered or unexported fields
}

Connections is an array of Connection

func (*Connections) Aggregate 

func (c *Connections) Aggregate(aggregate Aggregate, field string) float64

func (*Connections) AsMap 

func (e *Connections) AsMap() map[string]interface{}

func (*Connections) Descriptor deprecated 

func (*Connections) Descriptor() ([]byte, []int)

Deprecated: Use Connections.ProtoReflect.Descriptor instead.

func (*Connections) GetConnections 

func (x *Connections) GetConnections() []*Connection

func (*Connections) GetSeekNext 

func (x *Connections) GetSeekNext() string

func (*Connections) ProtoMessage 

func (*Connections) ProtoMessage()

func (*Connections) ProtoReflect 

func (x *Connections) ProtoReflect() protoreflect.Message

func (*Connections) Range 

func (d *Connections) Range(fn func(d *Connection) bool)

func (*Connections) Reset 

func (x *Connections) Reset()

func (*Connections) Sort 

func (e *Connections) Sort(field string)

func (*Connections) String 

func (x *Connections) String() string

func (*Connections) Validate 

func (this *Connections) Validate() error

type Constraint 

type Constraint struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Gtype      string `protobuf:"bytes,2,opt,name=gtype,proto3" json:"gtype,omitempty"`
	Expression string `protobuf:"bytes,3,opt,name=expression,proto3" json:"expression,omitempty"`
	// if target_docs is true, this validator will be applied to documents.
	TargetDocs bool `protobuf:"varint,4,opt,name=target_docs,json=targetDocs,proto3" json:"target_docs,omitempty"`
	// if target_connections is true, this validator will be applied to connections.
	TargetConnections bool `protobuf:"varint,5,opt,name=target_connections,json=targetConnections,proto3" json:"target_connections,omitempty"`
	// contains filtered or unexported fields
}

Constraint a graph primitive used to validate custom doc/connection constraints

func (*Constraint) Descriptor deprecated 

func (*Constraint) Descriptor() ([]byte, []int)

Deprecated: Use Constraint.ProtoReflect.Descriptor instead.

func (*Constraint) GetExpression 

func (x *Constraint) GetExpression() string

func (*Constraint) GetGtype 

func (x *Constraint) GetGtype() string

func (*Constraint) GetName 

func (x *Constraint) GetName() string

func (*Constraint) GetTargetConnections 

func (x *Constraint) GetTargetConnections() bool

func (*Constraint) GetTargetDocs 

func (x *Constraint) GetTargetDocs() bool

func (*Constraint) ProtoMessage 

func (*Constraint) ProtoMessage()

func (*Constraint) ProtoReflect 

func (x *Constraint) ProtoReflect() protoreflect.Message

func (*Constraint) Reset 

func (x *Constraint) Reset()

func (*Constraint) String 

func (x *Constraint) String() string

func (*Constraint) Validate 

func (this *Constraint) Validate() error

type Constraints 

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

func (*Constraints) Descriptor deprecated 

func (*Constraints) Descriptor() ([]byte, []int)

Deprecated: Use Constraints.ProtoReflect.Descriptor instead.

func (*Constraints) GetConstraints 

func (x *Constraints) GetConstraints() []*Constraint

func (*Constraints) ProtoMessage 

func (*Constraints) ProtoMessage()

func (*Constraints) ProtoReflect 

func (x *Constraints) ProtoReflect() protoreflect.Message

func (*Constraints) Reset 

func (x *Constraints) Reset()

func (*Constraints) String 

func (x *Constraints) String() string

func (*Constraints) Validate 

func (this *Constraints) Validate() error

type DatabaseServiceClient 

type DatabaseServiceClient interface {
	// GetSchema gets schema about the Graph doc & connection types
	GetSchema(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Schema, error)
	// SetAuthorizers sets all of the authorizers in the graph database
	SetAuthorizers(ctx context.Context, in *Authorizers, opts ...grpc.CallOption) (*empty.Empty, error)
	// SetIndexes sets all of the indexes in the graph database
	SetIndexes(ctx context.Context, in *Indexes, opts ...grpc.CallOption) (*empty.Empty, error)
	// SetConstraints sets all of the constraints in the graph database
	SetConstraints(ctx context.Context, in *Constraints, opts ...grpc.CallOption) (*empty.Empty, error)
	// SetTriggers sets all of the triggers in the graph database
	SetTriggers(ctx context.Context, in *Triggers, opts ...grpc.CallOption) (*empty.Empty, error)
	// Me returns a Doc of the currently logged in user
	Me(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Doc, error)
	// CreateDoc creates a doc in the graph
	CreateDoc(ctx context.Context, in *DocConstructor, opts ...grpc.CallOption) (*Doc, error)
	// CreateDocs creates a batch of docs in the graph
	CreateDocs(ctx context.Context, in *DocConstructors, opts ...grpc.CallOption) (*Docs, error)
	// PutDoc create-or-replaces a Doc in the graph
	PutDoc(ctx context.Context, in *Doc, opts ...grpc.CallOption) (*Doc, error)
	// PutDocs puts a batch of docs in the graph
	PutDocs(ctx context.Context, in *Docs, opts ...grpc.CallOption) (*Docs, error)
	// GetDoc gets a single doc in the graph
	GetDoc(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*Doc, error)
	// SearchDocs searches the graph for docs
	SearchDocs(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*Docs, error)
	// Traverse executes a depth first search of the graph for docs
	Traverse(ctx context.Context, in *TraverseFilter, opts ...grpc.CallOption) (*Traversals, error)
	// TraverseMe executes a graph traversal searching for docs related to the currently logged in user
	TraverseMe(ctx context.Context, in *TraverseMeFilter, opts ...grpc.CallOption) (*Traversals, error)
	// EditDoc patches/edits a docs attributes
	EditDoc(ctx context.Context, in *Edit, opts ...grpc.CallOption) (*Doc, error)
	// EditDocs patches a batch of docs attributes that pass the patch filter
	EditDocs(ctx context.Context, in *EditFilter, opts ...grpc.CallOption) (*Docs, error)
	// DelDoc deletes a doc & all of it's connected connections
	DelDoc(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*empty.Empty, error)
	// DelDocs deletes a batch of docs that pass the filter
	DelDocs(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*empty.Empty, error)
	// ExistsDoc searches for a Doc and returns a Boolean indicating if it exists in the graph
	ExistsDoc(ctx context.Context, in *ExistsFilter, opts ...grpc.CallOption) (*Boolean, error)
	// ExistsConnection searches for a Connection and returns a Boolean indicating if it exists in the graph
	ExistsConnection(ctx context.Context, in *ExistsFilter, opts ...grpc.CallOption) (*Boolean, error)
	// HasDoc searches for the Doc by Ref returns a Boolean indicating if it exists in the graph
	HasDoc(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*Boolean, error)
	// HasConnection searches for the Connection by Ref returns a Boolean indicating if it exists in the graph
	HasConnection(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*Boolean, error)
	// CreateConnection creates an connection in the graph
	CreateConnection(ctx context.Context, in *ConnectionConstructor, opts ...grpc.CallOption) (*Connection, error)
	// CreateConnections creates a batch of connections in the graph
	CreateConnections(ctx context.Context, in *ConnectionConstructors, opts ...grpc.CallOption) (*Connections, error)
	// PutConnection create-or-replaces a Connection in the graph
	PutConnection(ctx context.Context, in *Connection, opts ...grpc.CallOption) (*Connection, error)
	// PutConnections puts a batch of connections in the graph
	PutConnections(ctx context.Context, in *Connections, opts ...grpc.CallOption) (*Connections, error)
	// searches for documents and forms connections based on whether they pass a filter
	SearchAndConnect(ctx context.Context, in *SearchConnectFilter, opts ...grpc.CallOption) (*Connections, error)
	// SearchAndConnectMe searches for documents and forms connections from the origin user to the document based on whether they pass a filter
	SearchAndConnectMe(ctx context.Context, in *SearchConnectMeFilter, opts ...grpc.CallOption) (*Connections, error)
	// GetConnection gets a single connection in the graph
	GetConnection(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*Connection, error)
	// SearchConnections searches the graph for connections
	SearchConnections(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*Connections, error)
	// EditConnection patches an connections attributes
	EditConnection(ctx context.Context, in *Edit, opts ...grpc.CallOption) (*Connection, error)
	// EditConnections patches a batch of connections attributes that pass the patch filter
	EditConnections(ctx context.Context, in *EditFilter, opts ...grpc.CallOption) (*Connections, error)
	// DelConnection deletes an connection from the graph
	DelConnection(ctx context.Context, in *Ref, opts ...grpc.CallOption) (*empty.Empty, error)
	// DelConnections deletes a batch of connections that pass the filter
	DelConnections(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*empty.Empty, error)
	// ConnectionsFrom returns connections that source from the given doc ref that pass the filter
	ConnectionsFrom(ctx context.Context, in *ConnectFilter, opts ...grpc.CallOption) (*Connections, error)
	// ConnectionsTo returns connections that point to the given doc ref that pass the filter
	ConnectionsTo(ctx context.Context, in *ConnectFilter, opts ...grpc.CallOption) (*Connections, error)
	// AggregateDocs executes an aggregation function against the graph
	AggregateDocs(ctx context.Context, in *AggFilter, opts ...grpc.CallOption) (*Number, error)
	AggregateConnections(ctx context.Context, in *AggFilter, opts ...grpc.CallOption) (*Number, error)
	// Broadcast broadcasts a message to a pubsub channel
	Broadcast(ctx context.Context, in *OutboundMessage, opts ...grpc.CallOption) (*empty.Empty, error)
	// Stream subscribes to messages on a pubsub channel
	Stream(ctx context.Context, in *StreamFilter, opts ...grpc.CallOption) (DatabaseService_StreamClient, error)
	// PushDocConstructors streams DocConstructor to the server, creating them as they're sent and streaming the new doc to the client
	PushDocConstructors(ctx context.Context, opts ...grpc.CallOption) (DatabaseService_PushDocConstructorsClient, error)
	// PushConnectionConstructors streams ConnectionConstructor to the server, creating them as they're sent and streaming the new connection to the client
	PushConnectionConstructors(ctx context.Context, opts ...grpc.CallOption) (DatabaseService_PushConnectionConstructorsClient, error)
	SeedDocs(ctx context.Context, opts ...grpc.CallOption) (DatabaseService_SeedDocsClient, error)
	SeedConnections(ctx context.Context, opts ...grpc.CallOption) (DatabaseService_SeedConnectionsClient, error)
}

DatabaseServiceClient is the client API for DatabaseService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDatabaseServiceClient 

func NewDatabaseServiceClient(cc grpc.ClientConnInterface) DatabaseServiceClient

type DatabaseServiceServer 

type DatabaseServiceServer interface {
	// GetSchema gets schema about the Graph doc & connection types
	GetSchema(context.Context, *empty.Empty) (*Schema, error)
	// SetAuthorizers sets all of the authorizers in the graph database
	SetAuthorizers(context.Context, *Authorizers) (*empty.Empty, error)
	// SetIndexes sets all of the indexes in the graph database
	SetIndexes(context.Context, *Indexes) (*empty.Empty, error)
	// SetConstraints sets all of the constraints in the graph database
	SetConstraints(context.Context, *Constraints) (*empty.Empty, error)
	// SetTriggers sets all of the triggers in the graph database
	SetTriggers(context.Context, *Triggers) (*empty.Empty, error)
	// Me returns a Doc of the currently logged in user
	Me(context.Context, *empty.Empty) (*Doc, error)
	// CreateDoc creates a doc in the graph
	CreateDoc(context.Context, *DocConstructor) (*Doc, error)
	// CreateDocs creates a batch of docs in the graph
	CreateDocs(context.Context, *DocConstructors) (*Docs, error)
	// PutDoc create-or-replaces a Doc in the graph
	PutDoc(context.Context, *Doc) (*Doc, error)
	// PutDocs puts a batch of docs in the graph
	PutDocs(context.Context, *Docs) (*Docs, error)
	// GetDoc gets a single doc in the graph
	GetDoc(context.Context, *Ref) (*Doc, error)
	// SearchDocs searches the graph for docs
	SearchDocs(context.Context, *Filter) (*Docs, error)
	// Traverse executes a depth first search of the graph for docs
	Traverse(context.Context, *TraverseFilter) (*Traversals, error)
	// TraverseMe executes a graph traversal searching for docs related to the currently logged in user
	TraverseMe(context.Context, *TraverseMeFilter) (*Traversals, error)
	// EditDoc patches/edits a docs attributes
	EditDoc(context.Context, *Edit) (*Doc, error)
	// EditDocs patches a batch of docs attributes that pass the patch filter
	EditDocs(context.Context, *EditFilter) (*Docs, error)
	// DelDoc deletes a doc & all of it's connected connections
	DelDoc(context.Context, *Ref) (*empty.Empty, error)
	// DelDocs deletes a batch of docs that pass the filter
	DelDocs(context.Context, *Filter) (*empty.Empty, error)
	// ExistsDoc searches for a Doc and returns a Boolean indicating if it exists in the graph
	ExistsDoc(context.Context, *ExistsFilter) (*Boolean, error)
	// ExistsConnection searches for a Connection and returns a Boolean indicating if it exists in the graph
	ExistsConnection(context.Context, *ExistsFilter) (*Boolean, error)
	// HasDoc searches for the Doc by Ref returns a Boolean indicating if it exists in the graph
	HasDoc(context.Context, *Ref) (*Boolean, error)
	// HasConnection searches for the Connection by Ref returns a Boolean indicating if it exists in the graph
	HasConnection(context.Context, *Ref) (*Boolean, error)
	// CreateConnection creates an connection in the graph
	CreateConnection(context.Context, *ConnectionConstructor) (*Connection, error)
	// CreateConnections creates a batch of connections in the graph
	CreateConnections(context.Context, *ConnectionConstructors) (*Connections, error)
	// PutConnection create-or-replaces a Connection in the graph
	PutConnection(context.Context, *Connection) (*Connection, error)
	// PutConnections puts a batch of connections in the graph
	PutConnections(context.Context, *Connections) (*Connections, error)
	// searches for documents and forms connections based on whether they pass a filter
	SearchAndConnect(context.Context, *SearchConnectFilter) (*Connections, error)
	// SearchAndConnectMe searches for documents and forms connections from the origin user to the document based on whether they pass a filter
	SearchAndConnectMe(context.Context, *SearchConnectMeFilter) (*Connections, error)
	// GetConnection gets a single connection in the graph
	GetConnection(context.Context, *Ref) (*Connection, error)
	// SearchConnections searches the graph for connections
	SearchConnections(context.Context, *Filter) (*Connections, error)
	// EditConnection patches an connections attributes
	EditConnection(context.Context, *Edit) (*Connection, error)
	// EditConnections patches a batch of connections attributes that pass the patch filter
	EditConnections(context.Context, *EditFilter) (*Connections, error)
	// DelConnection deletes an connection from the graph
	DelConnection(context.Context, *Ref) (*empty.Empty, error)
	// DelConnections deletes a batch of connections that pass the filter
	DelConnections(context.Context, *Filter) (*empty.Empty, error)
	// ConnectionsFrom returns connections that source from the given doc ref that pass the filter
	ConnectionsFrom(context.Context, *ConnectFilter) (*Connections, error)
	// ConnectionsTo returns connections that point to the given doc ref that pass the filter
	ConnectionsTo(context.Context, *ConnectFilter) (*Connections, error)
	// AggregateDocs executes an aggregation function against the graph
	AggregateDocs(context.Context, *AggFilter) (*Number, error)
	AggregateConnections(context.Context, *AggFilter) (*Number, error)
	// Broadcast broadcasts a message to a pubsub channel
	Broadcast(context.Context, *OutboundMessage) (*empty.Empty, error)
	// Stream subscribes to messages on a pubsub channel
	Stream(*StreamFilter, DatabaseService_StreamServer) error
	// PushDocConstructors streams DocConstructor to the server, creating them as they're sent and streaming the new doc to the client
	PushDocConstructors(DatabaseService_PushDocConstructorsServer) error
	// PushConnectionConstructors streams ConnectionConstructor to the server, creating them as they're sent and streaming the new connection to the client
	PushConnectionConstructors(DatabaseService_PushConnectionConstructorsServer) error
	SeedDocs(DatabaseService_SeedDocsServer) error
	SeedConnections(DatabaseService_SeedConnectionsServer) error
}

DatabaseServiceServer is the server API for DatabaseService service.

type DatabaseService_PushConnectionConstructorsClient 

type DatabaseService_PushConnectionConstructorsClient interface {
	Send(*ConnectionConstructor) error
	Recv() (*Connection, error)
	grpc.ClientStream
}

type DatabaseService_PushConnectionConstructorsServer 

type DatabaseService_PushConnectionConstructorsServer interface {
	Send(*Connection) error
	Recv() (*ConnectionConstructor, error)
	grpc.ServerStream
}

type DatabaseService_PushDocConstructorsClient 

type DatabaseService_PushDocConstructorsClient interface {
	Send(*DocConstructor) error
	Recv() (*Doc, error)
	grpc.ClientStream
}

type DatabaseService_PushDocConstructorsServer 

type DatabaseService_PushDocConstructorsServer interface {
	Send(*Doc) error
	Recv() (*DocConstructor, error)
	grpc.ServerStream
}

type DatabaseService_SeedConnectionsClient 

type DatabaseService_SeedConnectionsClient interface {
	Send(*Connection) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type DatabaseService_SeedConnectionsServer 

type DatabaseService_SeedConnectionsServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*Connection, error)
	grpc.ServerStream
}

type DatabaseService_SeedDocsClient 

type DatabaseService_SeedDocsClient interface {
	Send(*Doc) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type DatabaseService_SeedDocsServer 

type DatabaseService_SeedDocsServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*Doc, error)
	grpc.ServerStream
}

type DatabaseService_StreamClient 

type DatabaseService_StreamClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type DatabaseService_StreamServer 

type DatabaseService_StreamServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type Doc 

type Doc struct {

	// ref is the ref to the doc
	Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// k/v pairs
	Attributes *_struct.Struct `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

Doc is a Graph primitive representing a single entity/resource. It is connected to other docs via Connections

func (*Doc) AsMap 

func (n *Doc) AsMap() map[string]interface{}

func (*Doc) Descriptor deprecated 

func (*Doc) Descriptor() ([]byte, []int)

Deprecated: Use Doc.ProtoReflect.Descriptor instead.

func (*Doc) GetAttributes 

func (x *Doc) GetAttributes() *_struct.Struct

func (*Doc) GetRef 

func (x *Doc) GetRef() *Ref

func (*Doc) ProtoMessage 

func (*Doc) ProtoMessage()

func (*Doc) ProtoReflect 

func (x *Doc) ProtoReflect() protoreflect.Message

func (*Doc) Reset 

func (x *Doc) Reset()

func (*Doc) String 

func (x *Doc) String() string

func (*Doc) Validate 

func (this *Doc) Validate() error

type DocConstructor 

type DocConstructor struct {

	// ref is the ref to the new Doc. If an id isn't present, one will be generated.
	Ref *RefConstructor `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// arbitrary k/v pairs
	Attributes *_struct.Struct `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

DocConstructor is used to create a doc

func (*DocConstructor) AsMap 

func (e *DocConstructor) AsMap() map[string]interface{}

func (*DocConstructor) Descriptor deprecated 

func (*DocConstructor) Descriptor() ([]byte, []int)

Deprecated: Use DocConstructor.ProtoReflect.Descriptor instead.

func (*DocConstructor) GetAttributes 

func (x *DocConstructor) GetAttributes() *_struct.Struct

func (*DocConstructor) GetRef 

func (x *DocConstructor) GetRef() *RefConstructor

func (*DocConstructor) ProtoMessage 

func (*DocConstructor) ProtoMessage()

func (*DocConstructor) ProtoReflect 

func (x *DocConstructor) ProtoReflect() protoreflect.Message

func (*DocConstructor) Reset 

func (x *DocConstructor) Reset()

func (*DocConstructor) String 

func (x *DocConstructor) String() string

func (*DocConstructor) Validate 

func (this *DocConstructor) Validate() error

type DocConstructors 

type DocConstructors struct {

	// docs is an array of doc constructors
	Docs []*DocConstructor `protobuf:"bytes,1,rep,name=docs,proto3" json:"docs,omitempty"`
	// contains filtered or unexported fields
}

DocConstructor is used to create a batch of docs

func (*DocConstructors) Descriptor deprecated 

func (*DocConstructors) Descriptor() ([]byte, []int)

Deprecated: Use DocConstructors.ProtoReflect.Descriptor instead.

func (*DocConstructors) GetDocs 

func (x *DocConstructors) GetDocs() []*DocConstructor

func (*DocConstructors) ProtoMessage 

func (*DocConstructors) ProtoMessage()

func (*DocConstructors) ProtoReflect 

func (x *DocConstructors) ProtoReflect() protoreflect.Message

func (*DocConstructors) Reset 

func (x *DocConstructors) Reset()

func (*DocConstructors) String 

func (x *DocConstructors) String() string

func (*DocConstructors) Validate 

func (this *DocConstructors) Validate() error

type Docs 

type Docs struct {

	// docs is an array of docs
	Docs     []*Doc `protobuf:"bytes,1,rep,name=docs,proto3" json:"docs,omitempty"`
	SeekNext string `protobuf:"bytes,2,opt,name=seek_next,json=seekNext,proto3" json:"seek_next,omitempty"`
	// contains filtered or unexported fields
}

Docs is an array of docs

func (*Docs) Aggregate 

func (d *Docs) Aggregate(aggregate Aggregate, field string) float64

func (*Docs) AsMap 

func (e *Docs) AsMap() map[string]interface{}

func (*Docs) Descriptor deprecated 

func (*Docs) Descriptor() ([]byte, []int)

Deprecated: Use Docs.ProtoReflect.Descriptor instead.

func (*Docs) GetDocs 

func (x *Docs) GetDocs() []*Doc

func (*Docs) GetSeekNext 

func (x *Docs) GetSeekNext() string

func (*Docs) ProtoMessage 

func (*Docs) ProtoMessage()

func (*Docs) ProtoReflect 

func (x *Docs) ProtoReflect() protoreflect.Message

func (*Docs) Range 

func (d *Docs) Range(fn func(d *Doc) bool)

func (*Docs) Reset 

func (x *Docs) Reset()

func (*Docs) Sort 

func (n *Docs) Sort(field string)

func (*Docs) String 

func (x *Docs) String() string

func (*Docs) Validate 

func (this *Docs) Validate() error

type Edit 

type Edit struct {

	// ref is the ref to the target doc/connection to patch
	Ref *Ref `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// attributes are k/v pairs used to overwrite k/v pairs on a doc/connection
	Attributes *_struct.Struct `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

Edit patches the attributes of a Doc or Connection

func (*Edit) AsMap 

func (p *Edit) AsMap() map[string]interface{}

func (*Edit) Descriptor deprecated 

func (*Edit) Descriptor() ([]byte, []int)

Deprecated: Use Edit.ProtoReflect.Descriptor instead.

func (*Edit) GetAttributes 

func (x *Edit) GetAttributes() *_struct.Struct

func (*Edit) GetRef 

func (x *Edit) GetRef() *Ref

func (*Edit) ProtoMessage 

func (*Edit) ProtoMessage()

func (*Edit) ProtoReflect 

func (x *Edit) ProtoReflect() protoreflect.Message

func (*Edit) Reset 

func (x *Edit) Reset()

func (*Edit) String 

func (x *Edit) String() string

func (*Edit) Validate 

func (this *Edit) Validate() error

type EditFilter 

type EditFilter struct {

	// filter is used to filter docs/connections to patch
	Filter *Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// attributes are k/v pairs used to overwrite k/v pairs on all docs/connections that pass the filter
	Attributes *_struct.Struct `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

EditFilter is used to patch/edit docs/connections

func (*EditFilter) AsMap 

func (n *EditFilter) AsMap() map[string]interface{}

func (*EditFilter) Descriptor deprecated 

func (*EditFilter) Descriptor() ([]byte, []int)

Deprecated: Use EditFilter.ProtoReflect.Descriptor instead.

func (*EditFilter) GetAttributes 

func (x *EditFilter) GetAttributes() *_struct.Struct

func (*EditFilter) GetFilter 

func (x *EditFilter) GetFilter() *Filter

func (*EditFilter) ProtoMessage 

func (*EditFilter) ProtoMessage()

func (*EditFilter) ProtoReflect 

func (x *EditFilter) ProtoReflect() protoreflect.Message

func (*EditFilter) Reset 

func (x *EditFilter) Reset()

func (*EditFilter) String 

func (x *EditFilter) String() string

func (*EditFilter) Validate 

func (this *EditFilter) Validate() error

type ExistsFilter 

type ExistsFilter struct {
	Gtype      string `protobuf:"bytes,1,opt,name=gtype,proto3" json:"gtype,omitempty"`
	Expression string `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"`
	// seek to a specific key for pagination
	Seek string `protobuf:"bytes,3,opt,name=seek,proto3" json:"seek,omitempty"`
	// reverse the results
	Reverse bool `protobuf:"varint,4,opt,name=reverse,proto3" json:"reverse,omitempty"`
	// search in a specific index
	Index string `protobuf:"bytes,5,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

ExistsFilter is used as input into all Exists(boolean) related queries.

func (*ExistsFilter) Descriptor deprecated 

func (*ExistsFilter) Descriptor() ([]byte, []int)

Deprecated: Use ExistsFilter.ProtoReflect.Descriptor instead.

func (*ExistsFilter) GetExpression 

func (x *ExistsFilter) GetExpression() string

func (*ExistsFilter) GetGtype 

func (x *ExistsFilter) GetGtype() string

func (*ExistsFilter) GetIndex 

func (x *ExistsFilter) GetIndex() string

func (*ExistsFilter) GetReverse 

func (x *ExistsFilter) GetReverse() bool

func (*ExistsFilter) GetSeek 

func (x *ExistsFilter) GetSeek() string

func (*ExistsFilter) ProtoMessage 

func (*ExistsFilter) ProtoMessage()

func (*ExistsFilter) ProtoReflect 

func (x *ExistsFilter) ProtoReflect() protoreflect.Message

func (*ExistsFilter) Reset 

func (x *ExistsFilter) Reset()

func (*ExistsFilter) String 

func (x *ExistsFilter) String() string

func (*ExistsFilter) Validate 

func (this *ExistsFilter) Validate() error

type ExprFilter 

type ExprFilter struct {

	// expression is a CEL expression used to filter connections/nodes
	Expression string `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

func (*ExprFilter) AsMap 

func (n *ExprFilter) AsMap() map[string]interface{}

func (*ExprFilter) Descriptor deprecated 

func (*ExprFilter) Descriptor() ([]byte, []int)

Deprecated: Use ExprFilter.ProtoReflect.Descriptor instead.

func (*ExprFilter) GetExpression 

func (x *ExprFilter) GetExpression() string

func (*ExprFilter) ProtoMessage 

func (*ExprFilter) ProtoMessage()

func (*ExprFilter) ProtoReflect 

func (x *ExprFilter) ProtoReflect() protoreflect.Message

func (*ExprFilter) Reset 

func (x *ExprFilter) Reset()

func (*ExprFilter) String 

func (x *ExprFilter) String() string

func (*ExprFilter) Validate 

func (this *ExprFilter) Validate() error

type Filter 

type Filter struct {

	// gtype is the doc/connection type to be filtered
	Gtype string `protobuf:"bytes,1,opt,name=gtype,proto3" json:"gtype,omitempty"`
	// expression is a CEL expression used to filter connections/modes
	Expression string `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"`
	// limit is the maximum number of items to return
	Limit uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// custom sorting of the results.
	Sort string `protobuf:"bytes,4,opt,name=sort,proto3" json:"sort,omitempty"`
	// seek to a specific key for pagination
	Seek string `protobuf:"bytes,5,opt,name=seek,proto3" json:"seek,omitempty"`
	// reverse the results
	Reverse bool `protobuf:"varint,6,opt,name=reverse,proto3" json:"reverse,omitempty"`
	// search in a specific index
	Index string `protobuf:"bytes,7,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

Filter is a generic filter using Common Expression Language

func (*Filter) AsMap 

func (n *Filter) AsMap() map[string]interface{}

func (*Filter) Descriptor deprecated 

func (*Filter) Descriptor() ([]byte, []int)

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetExpression 

func (x *Filter) GetExpression() string

func (*Filter) GetGtype 

func (x *Filter) GetGtype() string

func (*Filter) GetIndex 

func (x *Filter) GetIndex() string

func (*Filter) GetLimit 

func (x *Filter) GetLimit() uint64

func (*Filter) GetReverse 

func (x *Filter) GetReverse() bool

func (*Filter) GetSeek 

func (x *Filter) GetSeek() string

func (*Filter) GetSort 

func (x *Filter) GetSort() string

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

func (x *Filter) ProtoReflect() protoreflect.Message

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

func (*Filter) Validate 

func (this *Filter) Validate() error

type Flags 

type Flags struct {

	// open id connect discovery uri ex: https://accounts.google.com/.well-known/openid-configuration (env: GRAPHIK_OPEN_ID)
	OpenIdDiscovery string `protobuf:"bytes,1,opt,name=open_id_discovery,json=openIdDiscovery,proto3" json:"open_id_discovery,omitempty"`
	// persistant storage ref (env: GRAPHIK_STORAGE_PATH)
	StoragePath string `protobuf:"bytes,2,opt,name=storage_path,json=storagePath,proto3" json:"storage_path,omitempty"`
	// cors allow headers (env: GRAPHIK_ALLOW_HEADERS)
	AllowHeaders []string `protobuf:"bytes,5,rep,name=allow_headers,json=allowHeaders,proto3" json:"allow_headers,omitempty"`
	// cors allow methods (env: GRAPHIK_ALLOW_METHODS)
	AllowMethods []string `protobuf:"bytes,6,rep,name=allow_methods,json=allowMethods,proto3" json:"allow_methods,omitempty"`
	// cors allow origins (env: GRAPHIK_ALLOW_ORIGINS)
	AllowOrigins []string `protobuf:"bytes,7,rep,name=allow_origins,json=allowOrigins,proto3" json:"allow_origins,omitempty"`
	// root user is a list of email addresses that bypass authorizers. (env: GRAPHIK_ROOT_USERS)
	RootUsers                  []string `protobuf:"bytes,8,rep,name=root_users,json=rootUsers,proto3" json:"root_users,omitempty"`
	TlsCert                    string   `protobuf:"bytes,9,opt,name=tls_cert,json=tlsCert,proto3" json:"tls_cert,omitempty"`
	TlsKey                     string   `protobuf:"bytes,10,opt,name=tls_key,json=tlsKey,proto3" json:"tls_key,omitempty"`
	RequireRequestAuthorizers  bool     `` /* 140-byte string literal not displayed */
	RequireResponseAuthorizers bool     `` /* 143-byte string literal not displayed */
	JoinRaft                   string   `protobuf:"bytes,17,opt,name=join_raft,json=joinRaft,proto3" json:"join_raft,omitempty"`
	RaftPeerId                 string   `protobuf:"bytes,18,opt,name=raft_peer_id,json=raftPeerId,proto3" json:"raft_peer_id,omitempty"`
	ListenPort                 int64    `protobuf:"varint,19,opt,name=listen_port,json=listenPort,proto3" json:"listen_port,omitempty"`
	RaftSecret                 string   `protobuf:"bytes,20,opt,name=raft_secret,json=raftSecret,proto3" json:"raft_secret,omitempty"`
	Debug                      bool     `protobuf:"varint,21,opt,name=debug,proto3" json:"debug,omitempty"`
	Environment                string   `protobuf:"bytes,22,opt,name=environment,proto3" json:"environment,omitempty"`
	RaftAdvertise              string   `protobuf:"bytes,23,opt,name=raft_advertise,json=raftAdvertise,proto3" json:"raft_advertise,omitempty"`
	RaftMaxPool                int64    `protobuf:"varint,24,opt,name=raft_max_pool,json=raftMaxPool,proto3" json:"raft_max_pool,omitempty"`
	MutualTls                  bool     `protobuf:"varint,25,opt,name=mutual_tls,json=mutualTls,proto3" json:"mutual_tls,omitempty"`
	CaCert                     string   `protobuf:"bytes,26,opt,name=ca_cert,json=caCert,proto3" json:"ca_cert,omitempty"`
	EnableUi                   bool     `protobuf:"varint,27,opt,name=enable_ui,json=enableUi,proto3" json:"enable_ui,omitempty"`
	// contains filtered or unexported fields
}

func (*Flags) Descriptor deprecated 

func (*Flags) Descriptor() ([]byte, []int)

Deprecated: Use Flags.ProtoReflect.Descriptor instead.

func (*Flags) GetAllowHeaders 

func (x *Flags) GetAllowHeaders() []string

func (*Flags) GetAllowMethods 

func (x *Flags) GetAllowMethods() []string

func (*Flags) GetAllowOrigins 

func (x *Flags) GetAllowOrigins() []string

func (*Flags) GetCaCert added in v1.1.2 

func (x *Flags) GetCaCert() string

func (*Flags) GetDebug 

func (x *Flags) GetDebug() bool

func (*Flags) GetEnableUi added in v1.4.0 

func (x *Flags) GetEnableUi() bool

func (*Flags) GetEnvironment 

func (x *Flags) GetEnvironment() string

func (*Flags) GetJoinRaft 

func (x *Flags) GetJoinRaft() string

func (*Flags) GetListenPort 

func (x *Flags) GetListenPort() int64

func (*Flags) GetMutualTls added in v1.1.2 

func (x *Flags) GetMutualTls() bool

func (*Flags) GetOpenIdDiscovery 

func (x *Flags) GetOpenIdDiscovery() string

func (*Flags) GetRaftAdvertise 

func (x *Flags) GetRaftAdvertise() string

func (*Flags) GetRaftMaxPool 

func (x *Flags) GetRaftMaxPool() int64

func (*Flags) GetRaftPeerId 

func (x *Flags) GetRaftPeerId() string

func (*Flags) GetRaftSecret 

func (x *Flags) GetRaftSecret() string

func (*Flags) GetRequireRequestAuthorizers 

func (x *Flags) GetRequireRequestAuthorizers() bool

func (*Flags) GetRequireResponseAuthorizers 

func (x *Flags) GetRequireResponseAuthorizers() bool

func (*Flags) GetRootUsers 

func (x *Flags) GetRootUsers() []string

func (*Flags) GetStoragePath 

func (x *Flags) GetStoragePath() string

func (*Flags) GetTlsCert 

func (x *Flags) GetTlsCert() string

func (*Flags) GetTlsKey 

func (x *Flags) GetTlsKey() string

func (*Flags) ProtoMessage 

func (*Flags) ProtoMessage()

func (*Flags) ProtoReflect 

func (x *Flags) ProtoReflect() protoreflect.Message

func (*Flags) Reset 

func (x *Flags) Reset()

func (*Flags) String 

func (x *Flags) String() string

func (*Flags) Validate 

func (this *Flags) Validate() error

type Graph 

type Graph struct {

	// docs are docs present in the graph
	Docs *Docs `protobuf:"bytes,1,opt,name=docs,proto3" json:"docs,omitempty"`
	// connections are connections present in the graph
	Connections *Connections `protobuf:"bytes,2,opt,name=connections,proto3" json:"connections,omitempty"`
	// contains filtered or unexported fields
}

Graph is an array of docs and connections

func (*Graph) AsMap 

func (g *Graph) AsMap() map[string]interface{}

func (*Graph) Descriptor deprecated 

func (*Graph) Descriptor() ([]byte, []int)

Deprecated: Use Graph.ProtoReflect.Descriptor instead.

func (*Graph) GetConnections 

func (x *Graph) GetConnections() *Connections

func (*Graph) GetDocs 

func (x *Graph) GetDocs() *Docs

func (*Graph) ProtoMessage 

func (*Graph) ProtoMessage()

func (*Graph) ProtoReflect 

func (x *Graph) ProtoReflect() protoreflect.Message

func (*Graph) Reset 

func (x *Graph) Reset()

func (*Graph) String 

func (x *Graph) String() string

func (*Graph) Validate 

func (this *Graph) Validate() error

type Index 

type Index struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// gtype is the doc/connection type to be filtered
	Gtype string `protobuf:"bytes,3,opt,name=gtype,proto3" json:"gtype,omitempty"`
	// expression is a CEL expression used to filter connections/modes
	Expression string `protobuf:"bytes,4,opt,name=expression,proto3" json:"expression,omitempty"`
	// if target_docs is true, this index will be applied to documents.
	TargetDocs bool `protobuf:"varint,5,opt,name=target_docs,json=targetDocs,proto3" json:"target_docs,omitempty"`
	// if target_connections is true, this index will be applied to connections.
	TargetConnections bool `protobuf:"varint,6,opt,name=target_connections,json=targetConnections,proto3" json:"target_connections,omitempty"`
	// contains filtered or unexported fields
}

Index is a secondary index

func (*Index) Descriptor deprecated 

func (*Index) Descriptor() ([]byte, []int)

Deprecated: Use Index.ProtoReflect.Descriptor instead.

func (*Index) GetExpression 

func (x *Index) GetExpression() string

func (*Index) GetGtype 

func (x *Index) GetGtype() string

func (*Index) GetName 

func (x *Index) GetName() string

func (*Index) GetTargetConnections 

func (x *Index) GetTargetConnections() bool

func (*Index) GetTargetDocs 

func (x *Index) GetTargetDocs() bool

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) ProtoReflect 

func (x *Index) ProtoReflect() protoreflect.Message

func (*Index) Reset 

func (x *Index) Reset()

func (*Index) String 

func (x *Index) String() string

func (*Index) Validate 

func (this *Index) Validate() error

type IndexConstructor 

type IndexConstructor struct {

	// name is the unique name of the Index
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// gtype is the doc/connection type to be filtered
	Gtype string `protobuf:"bytes,3,opt,name=gtype,proto3" json:"gtype,omitempty"`
	// expression is a CEL expression used to filter connections/modes
	Expression string `protobuf:"bytes,4,opt,name=expression,proto3" json:"expression,omitempty"`
	// if target_docs is true, this index will be applied to documents.
	TargetDocs bool `protobuf:"varint,6,opt,name=target_docs,json=targetDocs,proto3" json:"target_docs,omitempty"`
	// if target_connections is true, this index will be applied to connections.
	TargetConnections bool `protobuf:"varint,7,opt,name=target_connections,json=targetConnections,proto3" json:"target_connections,omitempty"`
	// contains filtered or unexported fields
}

IndexConstructor is used to construct Indexes

func (*IndexConstructor) Descriptor deprecated 

func (*IndexConstructor) Descriptor() ([]byte, []int)

Deprecated: Use IndexConstructor.ProtoReflect.Descriptor instead.

func (*IndexConstructor) GetExpression 

func (x *IndexConstructor) GetExpression() string

func (*IndexConstructor) GetGtype 

func (x *IndexConstructor) GetGtype() string

func (*IndexConstructor) GetName 

func (x *IndexConstructor) GetName() string

func (*IndexConstructor) GetTargetConnections 

func (x *IndexConstructor) GetTargetConnections() bool

func (*IndexConstructor) GetTargetDocs 

func (x *IndexConstructor) GetTargetDocs() bool

func (*IndexConstructor) ProtoMessage 

func (*IndexConstructor) ProtoMessage()

func (*IndexConstructor) ProtoReflect 

func (x *IndexConstructor) ProtoReflect() protoreflect.Message

func (*IndexConstructor) Reset 

func (x *IndexConstructor) Reset()

func (*IndexConstructor) String 

func (x *IndexConstructor) String() string

func (*IndexConstructor) Validate 

func (this *IndexConstructor) Validate() error

type Indexes 

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

Indexes is an array of Index

func (*Indexes) Descriptor deprecated 

func (*Indexes) Descriptor() ([]byte, []int)

Deprecated: Use Indexes.ProtoReflect.Descriptor instead.

func (*Indexes) GetIndexes 

func (x *Indexes) GetIndexes() []*Index

func (*Indexes) ProtoMessage 

func (*Indexes) ProtoMessage()

func (*Indexes) ProtoReflect 

func (x *Indexes) ProtoReflect() protoreflect.Message

func (*Indexes) Reset 

func (x *Indexes) Reset()

func (*Indexes) String 

func (x *Indexes) String() string

func (*Indexes) Validate 

func (this *Indexes) Validate() error

type Mapper 

type Mapper interface {
	AsMap() map[string]interface{}
}

type Membership 

type Membership int32
const (
	Membership_UNKNOWN   Membership = 0
	Membership_FOLLOWER  Membership = 1
	Membership_CANDIDATE Membership = 2
	Membership_LEADER    Membership = 3
	Membership_SHUTDOWN  Membership = 4
)

func (Membership) Descriptor 

func (Membership) Descriptor() protoreflect.EnumDescriptor

func (Membership) Enum 

func (x Membership) Enum() *Membership

func (Membership) EnumDescriptor deprecated 

func (Membership) EnumDescriptor() ([]byte, []int)

Deprecated: Use Membership.Descriptor instead.

func (Membership) Number 

func (x Membership) Number() protoreflect.EnumNumber

func (Membership) String 

func (x Membership) String() string

func (Membership) Type 

func (Membership) Type() protoreflect.EnumType

type Message 

type Message struct {

	// channel is the channel the message was sent to
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// data is the data sent with the message
	Data *_struct.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// user is the sender that triggered/sent the message
	User *Ref `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	// timestamp is when the message was sent
	Timestamp *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Method    string               `protobuf:"bytes,5,opt,name=method,proto3" json:"method,omitempty"`
	// contains filtered or unexported fields
}

Message is received on PubSub subscriptions

func (*Message) AsMap 

func (n *Message) AsMap() map[string]interface{}

func (*Message) Descriptor deprecated 

func (*Message) Descriptor() ([]byte, []int)

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetChannel 

func (x *Message) GetChannel() string

func (*Message) GetData 

func (x *Message) GetData() *_struct.Struct

func (*Message) GetMethod 

func (x *Message) GetMethod() string

func (*Message) GetTimestamp 

func (x *Message) GetTimestamp() *timestamp.Timestamp

func (*Message) GetUser 

func (x *Message) GetUser() *Ref

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

func (*Message) Validate 

func (this *Message) Validate() error

type Number 

type Number struct {
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Number is a simple double/float64 value

func (*Number) Descriptor deprecated 

func (*Number) Descriptor() ([]byte, []int)

Deprecated: Use Number.ProtoReflect.Descriptor instead.

func (*Number) GetValue 

func (x *Number) GetValue() float64

func (*Number) ProtoMessage 

func (*Number) ProtoMessage()

func (*Number) ProtoReflect 

func (x *Number) ProtoReflect() protoreflect.Message

func (*Number) Reset 

func (x *Number) Reset()

func (*Number) String 

func (x *Number) String() string

func (*Number) Validate 

func (this *Number) Validate() error

type OutboundMessage 

type OutboundMessage struct {

	// channel is the target channel to send the message to
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// data is the data to send with the message
	Data *_struct.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

OutboundMessage is a message to be published to a pubsub channel

func (*OutboundMessage) AsMap 

func (o *OutboundMessage) AsMap() map[string]interface{}

func (*OutboundMessage) Descriptor deprecated 

func (*OutboundMessage) Descriptor() ([]byte, []int)

Deprecated: Use OutboundMessage.ProtoReflect.Descriptor instead.

func (*OutboundMessage) GetChannel 

func (x *OutboundMessage) GetChannel() string

func (*OutboundMessage) GetData 

func (x *OutboundMessage) GetData() *_struct.Struct

func (*OutboundMessage) ProtoMessage 

func (*OutboundMessage) ProtoMessage()

func (*OutboundMessage) ProtoReflect 

func (x *OutboundMessage) ProtoReflect() protoreflect.Message

func (*OutboundMessage) Reset 

func (x *OutboundMessage) Reset()

func (*OutboundMessage) String 

func (x *OutboundMessage) String() string

func (*OutboundMessage) Validate 

func (this *OutboundMessage) Validate() error

type Peer 

type Peer struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Addr   string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*Peer) Descriptor deprecated 

func (*Peer) Descriptor() ([]byte, []int)

Deprecated: Use Peer.ProtoReflect.Descriptor instead.

func (*Peer) GetAddr 

func (x *Peer) GetAddr() string

func (*Peer) GetNodeId 

func (x *Peer) GetNodeId() string

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) ProtoReflect 

func (x *Peer) ProtoReflect() protoreflect.Message

func (*Peer) Reset 

func (x *Peer) Reset()

func (*Peer) String 

func (x *Peer) String() string

func (*Peer) Validate 

func (this *Peer) Validate() error

type Pong 

type Pong struct {

	// message returns PONG if healthy
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Pong returns PONG if the server is healthy

func (*Pong) Descriptor deprecated 

func (*Pong) Descriptor() ([]byte, []int)

Deprecated: Use Pong.ProtoReflect.Descriptor instead.

func (*Pong) GetMessage 

func (x *Pong) GetMessage() string

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) ProtoReflect 

func (x *Pong) ProtoReflect() protoreflect.Message

func (*Pong) Reset 

func (x *Pong) Reset()

func (*Pong) String 

func (x *Pong) String() string

func (*Pong) Validate 

func (this *Pong) Validate() error

type RaftCommand 

type RaftCommand struct {
	User           *Doc          `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Method         string        `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	SetDocs        []*Doc        `protobuf:"bytes,3,rep,name=set_docs,json=setDocs,proto3" json:"set_docs,omitempty"`
	SetConnections []*Connection `protobuf:"bytes,4,rep,name=set_connections,json=setConnections,proto3" json:"set_connections,omitempty"`
	DelDocs        []*Ref        `protobuf:"bytes,5,rep,name=del_docs,json=delDocs,proto3" json:"del_docs,omitempty"`
	DelConnections []*Ref        `protobuf:"bytes,6,rep,name=del_connections,json=delConnections,proto3" json:"del_connections,omitempty"`
	SetIndexes     *Indexes      `protobuf:"bytes,7,opt,name=set_indexes,json=setIndexes,proto3" json:"set_indexes,omitempty"`
	SetAuthorizers *Authorizers  `protobuf:"bytes,8,opt,name=set_authorizers,json=setAuthorizers,proto3" json:"set_authorizers,omitempty"`
	SetConstraints *Constraints  `protobuf:"bytes,9,opt,name=set_constraints,json=setConstraints,proto3" json:"set_constraints,omitempty"`
	SendMessage    *Message      `protobuf:"bytes,10,opt,name=send_message,json=sendMessage,proto3" json:"send_message,omitempty"`
	SetTriggers    *Triggers     `protobuf:"bytes,11,opt,name=set_triggers,json=setTriggers,proto3" json:"set_triggers,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftCommand) Descriptor deprecated 

func (*RaftCommand) Descriptor() ([]byte, []int)

Deprecated: Use RaftCommand.ProtoReflect.Descriptor instead.

func (*RaftCommand) GetDelConnections 

func (x *RaftCommand) GetDelConnections() []*Ref

func (*RaftCommand) GetDelDocs 

func (x *RaftCommand) GetDelDocs() []*Ref

func (*RaftCommand) GetMethod 

func (x *RaftCommand) GetMethod() string

func (*RaftCommand) GetSendMessage 

func (x *RaftCommand) GetSendMessage() *Message

func (*RaftCommand) GetSetAuthorizers 

func (x *RaftCommand) GetSetAuthorizers() *Authorizers

func (*RaftCommand) GetSetConnections 

func (x *RaftCommand) GetSetConnections() []*Connection

func (*RaftCommand) GetSetConstraints 

func (x *RaftCommand) GetSetConstraints() *Constraints

func (*RaftCommand) GetSetDocs 

func (x *RaftCommand) GetSetDocs() []*Doc

func (*RaftCommand) GetSetIndexes 

func (x *RaftCommand) GetSetIndexes() *Indexes

func (*RaftCommand) GetSetTriggers 

func (x *RaftCommand) GetSetTriggers() *Triggers

func (*RaftCommand) GetUser 

func (x *RaftCommand) GetUser() *Doc

func (*RaftCommand) ProtoMessage 

func (*RaftCommand) ProtoMessage()

func (*RaftCommand) ProtoReflect 

func (x *RaftCommand) ProtoReflect() protoreflect.Message

func (*RaftCommand) Reset 

func (x *RaftCommand) Reset()

func (*RaftCommand) String 

func (x *RaftCommand) String() string

func (*RaftCommand) Validate 

func (this *RaftCommand) Validate() error

type RaftServiceClient 

type RaftServiceClient interface {
	// Ping returns PONG if the server is health
	Ping(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Pong, error)
	JoinCluster(ctx context.Context, in *Peer, opts ...grpc.CallOption) (*empty.Empty, error)
	ClusterState(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*RaftState, error)
}

RaftServiceClient is the client API for RaftService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRaftServiceClient 

func NewRaftServiceClient(cc grpc.ClientConnInterface) RaftServiceClient

type RaftServiceServer 

type RaftServiceServer interface {
	// Ping returns PONG if the server is health
	Ping(context.Context, *empty.Empty) (*Pong, error)
	JoinCluster(context.Context, *Peer) (*empty.Empty, error)
	ClusterState(context.Context, *empty.Empty) (*RaftState, error)
}

RaftServiceServer is the server API for RaftService service.

type RaftState 

type RaftState struct {
	Leader     string            `protobuf:"bytes,1,opt,name=leader,proto3" json:"leader,omitempty"`
	Membership Membership        `protobuf:"varint,2,opt,name=membership,proto3,enum=api.Membership" json:"membership,omitempty"`
	Peers      []*Peer           `protobuf:"bytes,3,rep,name=peers,proto3" json:"peers,omitempty"`
	Stats      map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RaftState) Descriptor deprecated 

func (*RaftState) Descriptor() ([]byte, []int)

Deprecated: Use RaftState.ProtoReflect.Descriptor instead.

func (*RaftState) GetLeader 

func (x *RaftState) GetLeader() string

func (*RaftState) GetMembership 

func (x *RaftState) GetMembership() Membership

func (*RaftState) GetPeers 

func (x *RaftState) GetPeers() []*Peer

func (*RaftState) GetStats 

func (x *RaftState) GetStats() map[string]string

func (*RaftState) ProtoMessage 

func (*RaftState) ProtoMessage()

func (*RaftState) ProtoReflect 

func (x *RaftState) ProtoReflect() protoreflect.Message

func (*RaftState) Reset 

func (x *RaftState) Reset()

func (*RaftState) String 

func (x *RaftState) String() string

func (*RaftState) Validate 

func (this *RaftState) Validate() error

type Ref 

type Ref struct {

	// gtype is the type of the doc/connection ex: pet
	Gtype string `protobuf:"bytes,1,opt,name=gtype,proto3" json:"gtype,omitempty"`
	// gid is the unique id of the doc/connection within the context of it's type
	Gid string `protobuf:"bytes,2,opt,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

Ref describes a doc/connection type & id

func (*Ref) AsMap 

func (m *Ref) AsMap() map[string]interface{}

func (*Ref) Descriptor deprecated 

func (*Ref) Descriptor() ([]byte, []int)

Deprecated: Use Ref.ProtoReflect.Descriptor instead.

func (*Ref) GetGid 

func (x *Ref) GetGid() string

func (*Ref) GetGtype 

func (x *Ref) GetGtype() string

func (*Ref) ProtoMessage 

func (*Ref) ProtoMessage()

func (*Ref) ProtoReflect 

func (x *Ref) ProtoReflect() protoreflect.Message

func (*Ref) Reset 

func (x *Ref) Reset()

func (*Ref) String 

func (x *Ref) String() string

func (*Ref) Validate 

func (this *Ref) Validate() error

type RefConstructor 

type RefConstructor struct {

	// gtype is the type of the doc/connection ex: pet
	Gtype string `protobuf:"bytes,1,opt,name=gtype,proto3" json:"gtype,omitempty"`
	// gid is the unique id of the doc/connection within the context of it's type
	Gid string `protobuf:"bytes,2,opt,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

RefConstructor creates a new Ref

func (*RefConstructor) AsMap 

func (e *RefConstructor) AsMap() map[string]interface{}

func (*RefConstructor) Descriptor deprecated 

func (*RefConstructor) Descriptor() ([]byte, []int)

Deprecated: Use RefConstructor.ProtoReflect.Descriptor instead.

func (*RefConstructor) GetGid 

func (x *RefConstructor) GetGid() string

func (*RefConstructor) GetGtype 

func (x *RefConstructor) GetGtype() string

func (*RefConstructor) ProtoMessage 

func (*RefConstructor) ProtoMessage()

func (*RefConstructor) ProtoReflect 

func (x *RefConstructor) ProtoReflect() protoreflect.Message

func (*RefConstructor) Reset 

func (x *RefConstructor) Reset()

func (*RefConstructor) String 

func (x *RefConstructor) String() string

func (*RefConstructor) Validate 

func (this *RefConstructor) Validate() error

type Refs 

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

Refs is an array of refs

func (*Refs) AsMap 

func (p *Refs) AsMap() map[string]interface{}

func (*Refs) Descriptor deprecated 

func (*Refs) Descriptor() ([]byte, []int)

Deprecated: Use Refs.ProtoReflect.Descriptor instead.

func (*Refs) GetRefs 

func (x *Refs) GetRefs() []*Ref

func (*Refs) ProtoMessage 

func (*Refs) ProtoMessage()

func (*Refs) ProtoReflect 

func (x *Refs) ProtoReflect() protoreflect.Message

func (*Refs) Reset 

func (x *Refs) Reset()

func (*Refs) Sort 

func (p *Refs) Sort(field string)

func (*Refs) String 

func (x *Refs) String() string

func (*Refs) Validate 

func (this *Refs) Validate() error

type Schema 

type Schema struct {

	// connection_types are the types of connections in the graph
	ConnectionTypes []string `protobuf:"bytes,1,rep,name=connection_types,json=connectionTypes,proto3" json:"connection_types,omitempty"`
	// doc_types are the types of docs in the graph
	DocTypes    []string     `protobuf:"bytes,2,rep,name=doc_types,json=docTypes,proto3" json:"doc_types,omitempty"`
	Authorizers *Authorizers `protobuf:"bytes,3,opt,name=authorizers,proto3" json:"authorizers,omitempty"`
	Constraints *Constraints `protobuf:"bytes,4,opt,name=constraints,proto3" json:"constraints,omitempty"`
	Indexes     *Indexes     `protobuf:"bytes,5,opt,name=indexes,proto3" json:"indexes,omitempty"`
	Triggers    *Triggers    `protobuf:"bytes,6,opt,name=triggers,proto3" json:"triggers,omitempty"`
	// contains filtered or unexported fields
}

Schema returns registered connection & doc types

func (*Schema) Descriptor deprecated 

func (*Schema) Descriptor() ([]byte, []int)

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetAuthorizers 

func (x *Schema) GetAuthorizers() *Authorizers

func (*Schema) GetConnectionTypes 

func (x *Schema) GetConnectionTypes() []string

func (*Schema) GetConstraints 

func (x *Schema) GetConstraints() *Constraints

func (*Schema) GetDocTypes 

func (x *Schema) GetDocTypes() []string

func (*Schema) GetIndexes 

func (x *Schema) GetIndexes() *Indexes

func (*Schema) GetTriggers 

func (x *Schema) GetTriggers() *Triggers

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect 

func (x *Schema) ProtoReflect() protoreflect.Message

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) String 

func (x *Schema) String() string

func (*Schema) Validate 

func (this *Schema) Validate() error

type SearchConnectFilter 

type SearchConnectFilter struct {
	Filter *Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Gtype  string  `protobuf:"bytes,2,opt,name=gtype,proto3" json:"gtype,omitempty"`
	// attributes are k/v pairs
	Attributes *_struct.Struct `protobuf:"bytes,3,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// directed is false if the connection is bi-directional
	Directed bool `protobuf:"varint,4,opt,name=directed,proto3" json:"directed,omitempty"`
	// from is the doc ref that is the root of the connection
	From *Ref `protobuf:"bytes,5,opt,name=from,proto3" json:"from,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchConnectFilter) Descriptor deprecated 

func (*SearchConnectFilter) Descriptor() ([]byte, []int)

Deprecated: Use SearchConnectFilter.ProtoReflect.Descriptor instead.

func (*SearchConnectFilter) GetAttributes 

func (x *SearchConnectFilter) GetAttributes() *_struct.Struct

func (*SearchConnectFilter) GetDirected 

func (x *SearchConnectFilter) GetDirected() bool

func (*SearchConnectFilter) GetFilter 

func (x *SearchConnectFilter) GetFilter() *Filter

func (*SearchConnectFilter) GetFrom 

func (x *SearchConnectFilter) GetFrom() *Ref

func (*SearchConnectFilter) GetGtype 

func (x *SearchConnectFilter) GetGtype() string

func (*SearchConnectFilter) ProtoMessage 

func (*SearchConnectFilter) ProtoMessage()

func (*SearchConnectFilter) ProtoReflect 

func (x *SearchConnectFilter) ProtoReflect() protoreflect.Message

func (*SearchConnectFilter) Reset 

func (x *SearchConnectFilter) Reset()

func (*SearchConnectFilter) String 

func (x *SearchConnectFilter) String() string

func (*SearchConnectFilter) Validate 

func (this *SearchConnectFilter) Validate() error

type SearchConnectMeFilter 

type SearchConnectMeFilter struct {
	Filter *Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Gtype  string  `protobuf:"bytes,2,opt,name=gtype,proto3" json:"gtype,omitempty"`
	// attributes are k/v pairs
	Attributes *_struct.Struct `protobuf:"bytes,3,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// directed is false if the connection is bi-directional
	Directed bool `protobuf:"varint,4,opt,name=directed,proto3" json:"directed,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchConnectMeFilter) Descriptor deprecated 

func (*SearchConnectMeFilter) Descriptor() ([]byte, []int)

Deprecated: Use SearchConnectMeFilter.ProtoReflect.Descriptor instead.

func (*SearchConnectMeFilter) GetAttributes 

func (x *SearchConnectMeFilter) GetAttributes() *_struct.Struct

func (*SearchConnectMeFilter) GetDirected 

func (x *SearchConnectMeFilter) GetDirected() bool

func (*SearchConnectMeFilter) GetFilter 

func (x *SearchConnectMeFilter) GetFilter() *Filter

func (*SearchConnectMeFilter) GetGtype 

func (x *SearchConnectMeFilter) GetGtype() string

func (*SearchConnectMeFilter) ProtoMessage 

func (*SearchConnectMeFilter) ProtoMessage()

func (*SearchConnectMeFilter) ProtoReflect 

func (x *SearchConnectMeFilter) ProtoReflect() protoreflect.Message

func (*SearchConnectMeFilter) Reset 

func (x *SearchConnectMeFilter) Reset()

func (*SearchConnectMeFilter) String 

func (x *SearchConnectMeFilter) String() string

func (*SearchConnectMeFilter) Validate 

func (this *SearchConnectMeFilter) Validate() error

type StreamFilter 

type StreamFilter struct {

	// channel is the target channel to filter from
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// expression is CEL expression used to filter messages
	Expression string `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"`
	// minimum message timestamp to stream (optional)
	Min *timestamp.Timestamp `protobuf:"bytes,3,opt,name=min,proto3" json:"min,omitempty"`
	// maximum message timestamp to stream (optional)
	Max *timestamp.Timestamp `protobuf:"bytes,4,opt,name=max,proto3" json:"max,omitempty"`
	// contains filtered or unexported fields
}

StreamFilter is used to filter messages in a pubsub channel

func (*StreamFilter) AsMap 

func (n *StreamFilter) AsMap() map[string]interface{}

func (*StreamFilter) Descriptor deprecated 

func (*StreamFilter) Descriptor() ([]byte, []int)

Deprecated: Use StreamFilter.ProtoReflect.Descriptor instead.

func (*StreamFilter) GetChannel 

func (x *StreamFilter) GetChannel() string

func (*StreamFilter) GetExpression 

func (x *StreamFilter) GetExpression() string

func (*StreamFilter) GetMax 

func (x *StreamFilter) GetMax() *timestamp.Timestamp

func (*StreamFilter) GetMin 

func (x *StreamFilter) GetMin() *timestamp.Timestamp

func (*StreamFilter) ProtoMessage 

func (*StreamFilter) ProtoMessage()

func (*StreamFilter) ProtoReflect 

func (x *StreamFilter) ProtoReflect() protoreflect.Message

func (*StreamFilter) Reset 

func (x *StreamFilter) Reset()

func (*StreamFilter) String 

func (x *StreamFilter) String() string

func (*StreamFilter) Validate 

func (this *StreamFilter) Validate() error

type Traversal 

type Traversal struct {
	Doc           *Doc   `protobuf:"bytes,1,opt,name=doc,proto3" json:"doc,omitempty"`
	TraversalPath []*Ref `protobuf:"bytes,2,rep,name=traversal_path,json=traversalPath,proto3" json:"traversal_path,omitempty"`
	Depth         uint64 `protobuf:"varint,3,opt,name=depth,proto3" json:"depth,omitempty"`
	Hops          uint64 `protobuf:"varint,4,opt,name=hops,proto3" json:"hops,omitempty"`
	// contains filtered or unexported fields
}

func (*Traversal) Descriptor deprecated 

func (*Traversal) Descriptor() ([]byte, []int)

Deprecated: Use Traversal.ProtoReflect.Descriptor instead.

func (*Traversal) GetDepth 

func (x *Traversal) GetDepth() uint64

func (*Traversal) GetDoc 

func (x *Traversal) GetDoc() *Doc

func (*Traversal) GetHops 

func (x *Traversal) GetHops() uint64

func (*Traversal) GetTraversalPath 

func (x *Traversal) GetTraversalPath() []*Ref

func (*Traversal) ProtoMessage 

func (*Traversal) ProtoMessage()

func (*Traversal) ProtoReflect 

func (x *Traversal) ProtoReflect() protoreflect.Message

func (*Traversal) Reset 

func (x *Traversal) Reset()

func (*Traversal) String 

func (x *Traversal) String() string

func (*Traversal) Validate 

func (this *Traversal) Validate() error

type Traversals 

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

func (*Traversals) Descriptor deprecated 

func (*Traversals) Descriptor() ([]byte, []int)

Deprecated: Use Traversals.ProtoReflect.Descriptor instead.

func (*Traversals) GetTraversals 

func (x *Traversals) GetTraversals() []*Traversal

func (*Traversals) ProtoMessage 

func (*Traversals) ProtoMessage()

func (*Traversals) ProtoReflect 

func (x *Traversals) ProtoReflect() protoreflect.Message

func (*Traversals) Reset 

func (x *Traversals) Reset()

func (*Traversals) String 

func (x *Traversals) String() string

func (*Traversals) Validate 

func (this *Traversals) Validate() error

type TraverseFilter 

type TraverseFilter struct {
	Root                 *Ref   `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
	DocExpression        string `protobuf:"bytes,2,opt,name=doc_expression,json=docExpression,proto3" json:"doc_expression,omitempty"`
	ConnectionExpression string `protobuf:"bytes,3,opt,name=connection_expression,json=connectionExpression,proto3" json:"connection_expression,omitempty"`
	Limit                uint64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// custom sorting of the results. (validator.field) = {regex : "((^|, )(|ref.gid|ref.gtype|^attributes.(.*)))+$"}
	Sort      string    `protobuf:"bytes,5,opt,name=sort,proto3" json:"sort,omitempty"`
	Reverse   bool      `protobuf:"varint,6,opt,name=reverse,proto3" json:"reverse,omitempty"`
	Algorithm Algorithm `protobuf:"varint,7,opt,name=algorithm,proto3,enum=api.Algorithm" json:"algorithm,omitempty"`
	// maximum degree/depth of nodes to be visited during traversal
	MaxDepth uint64 `protobuf:"varint,8,opt,name=max_depth,json=maxDepth,proto3" json:"max_depth,omitempty"`
	// maximum number of nodes to be visited during traversal
	MaxHops uint64 `protobuf:"varint,9,opt,name=max_hops,json=maxHops,proto3" json:"max_hops,omitempty"`
	// contains filtered or unexported fields
}

func (*TraverseFilter) Descriptor deprecated 

func (*TraverseFilter) Descriptor() ([]byte, []int)

Deprecated: Use TraverseFilter.ProtoReflect.Descriptor instead.

func (*TraverseFilter) GetAlgorithm 

func (x *TraverseFilter) GetAlgorithm() Algorithm

func (*TraverseFilter) GetConnectionExpression 

func (x *TraverseFilter) GetConnectionExpression() string

func (*TraverseFilter) GetDocExpression 

func (x *TraverseFilter) GetDocExpression() string

func (*TraverseFilter) GetLimit 

func (x *TraverseFilter) GetLimit() uint64

func (*TraverseFilter) GetMaxDepth 

func (x *TraverseFilter) GetMaxDepth() uint64

func (*TraverseFilter) GetMaxHops 

func (x *TraverseFilter) GetMaxHops() uint64

func (*TraverseFilter) GetReverse 

func (x *TraverseFilter) GetReverse() bool

func (*TraverseFilter) GetRoot 

func (x *TraverseFilter) GetRoot() *Ref

func (*TraverseFilter) GetSort 

func (x *TraverseFilter) GetSort() string

func (*TraverseFilter) ProtoMessage 

func (*TraverseFilter) ProtoMessage()

func (*TraverseFilter) ProtoReflect 

func (x *TraverseFilter) ProtoReflect() protoreflect.Message

func (*TraverseFilter) Reset 

func (x *TraverseFilter) Reset()

func (*TraverseFilter) String 

func (x *TraverseFilter) String() string

func (*TraverseFilter) Validate 

func (this *TraverseFilter) Validate() error

type TraverseMeFilter 

type TraverseMeFilter struct {
	DocExpression        string `protobuf:"bytes,1,opt,name=doc_expression,json=docExpression,proto3" json:"doc_expression,omitempty"`
	ConnectionExpression string `protobuf:"bytes,2,opt,name=connection_expression,json=connectionExpression,proto3" json:"connection_expression,omitempty"`
	Limit                uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// custom sorting of the results. (validator.field) = {regex : "((^|, )(|ref.gid|ref.gtype|^attributes.(.*)))+$"}
	Sort      string    `protobuf:"bytes,4,opt,name=sort,proto3" json:"sort,omitempty"`
	Reverse   bool      `protobuf:"varint,5,opt,name=reverse,proto3" json:"reverse,omitempty"`
	Algorithm Algorithm `protobuf:"varint,6,opt,name=algorithm,proto3,enum=api.Algorithm" json:"algorithm,omitempty"`
	// maximum degree/depth of nodes to be visited during traversal
	MaxDepth uint64 `protobuf:"varint,7,opt,name=max_depth,json=maxDepth,proto3" json:"max_depth,omitempty"`
	// maximum number of nodes to be visited during traversal
	MaxHops uint64 `protobuf:"varint,8,opt,name=max_hops,json=maxHops,proto3" json:"max_hops,omitempty"`
	// contains filtered or unexported fields
}

func (*TraverseMeFilter) Descriptor deprecated 

func (*TraverseMeFilter) Descriptor() ([]byte, []int)

Deprecated: Use TraverseMeFilter.ProtoReflect.Descriptor instead.

func (*TraverseMeFilter) GetAlgorithm 

func (x *TraverseMeFilter) GetAlgorithm() Algorithm

func (*TraverseMeFilter) GetConnectionExpression 

func (x *TraverseMeFilter) GetConnectionExpression() string

func (*TraverseMeFilter) GetDocExpression 

func (x *TraverseMeFilter) GetDocExpression() string

func (*TraverseMeFilter) GetLimit 

func (x *TraverseMeFilter) GetLimit() uint64

func (*TraverseMeFilter) GetMaxDepth 

func (x *TraverseMeFilter) GetMaxDepth() uint64

func (*TraverseMeFilter) GetMaxHops 

func (x *TraverseMeFilter) GetMaxHops() uint64

func (*TraverseMeFilter) GetReverse 

func (x *TraverseMeFilter) GetReverse() bool

func (*TraverseMeFilter) GetSort 

func (x *TraverseMeFilter) GetSort() string

func (*TraverseMeFilter) ProtoMessage 

func (*TraverseMeFilter) ProtoMessage()

func (*TraverseMeFilter) ProtoReflect 

func (x *TraverseMeFilter) ProtoReflect() protoreflect.Message

func (*TraverseMeFilter) Reset 

func (x *TraverseMeFilter) Reset()

func (*TraverseMeFilter) String 

func (x *TraverseMeFilter) String() string

func (*TraverseMeFilter) Validate 

func (this *TraverseMeFilter) Validate() error

type Trigger 

type Trigger struct {

	// name is the unique name of the authorizer
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// gtype is the type of doc/connection will invoke the trigger
	Gtype string `protobuf:"bytes,2,opt,name=gtype,proto3" json:"gtype,omitempty"`
	// trigger is the arrow syntax expression that mutates the doc/connection before it is stored ref: https://github.com/graphikDB/trigger
	Trigger string `protobuf:"bytes,4,opt,name=trigger,proto3" json:"trigger,omitempty"`
	// if target_docs is true, this trigger will be applied to documents.
	TargetDocs bool `protobuf:"varint,5,opt,name=target_docs,json=targetDocs,proto3" json:"target_docs,omitempty"`
	// if target_connections is true, this trigger will be applied to connections.
	TargetConnections bool `protobuf:"varint,6,opt,name=target_connections,json=targetConnections,proto3" json:"target_connections,omitempty"`
	// contains filtered or unexported fields
}

Trigger may be used to automatically mutate the attributes of documents/connections before they are commited to the database

func (*Trigger) Descriptor deprecated 

func (*Trigger) Descriptor() ([]byte, []int)

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetGtype 

func (x *Trigger) GetGtype() string

func (*Trigger) GetName 

func (x *Trigger) GetName() string

func (*Trigger) GetTargetConnections 

func (x *Trigger) GetTargetConnections() bool

func (*Trigger) GetTargetDocs 

func (x *Trigger) GetTargetDocs() bool

func (*Trigger) GetTrigger 

func (x *Trigger) GetTrigger() string

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect 

func (x *Trigger) ProtoReflect() protoreflect.Message

func (*Trigger) Reset 

func (x *Trigger) Reset()

func (*Trigger) String 

func (x *Trigger) String() string

func (*Trigger) Validate 

func (this *Trigger) Validate() error

type Triggers 

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

Triggers is an array of Trigger

func (*Triggers) Descriptor deprecated 

func (*Triggers) Descriptor() ([]byte, []int)

Deprecated: Use Triggers.ProtoReflect.Descriptor instead.

func (*Triggers) GetTriggers 

func (x *Triggers) GetTriggers() []*Trigger

func (*Triggers) ProtoMessage 

func (*Triggers) ProtoMessage()

func (*Triggers) ProtoReflect 

func (x *Triggers) ProtoReflect() protoreflect.Message

func (*Triggers) Reset 

func (x *Triggers) Reset()

func (*Triggers) String 

func (x *Triggers) String() string

func (*Triggers) Validate 

func (this *Triggers) Validate() error

type UIFlags added in v1.4.0 

type UIFlags struct {
	OauthClientId         string   `protobuf:"bytes,1,opt,name=oauth_client_id,json=oauthClientId,proto3" json:"oauth_client_id,omitempty"`
	OauthClientSecret     string   `protobuf:"bytes,2,opt,name=oauth_client_secret,json=oauthClientSecret,proto3" json:"oauth_client_secret,omitempty"`
	OauthAuthorizationUrl string   `` /* 126-byte string literal not displayed */
	OauthTokenUrl         string   `protobuf:"bytes,4,opt,name=oauth_token_url,json=oauthTokenUrl,proto3" json:"oauth_token_url,omitempty"`
	OauthRedirectUrl      string   `protobuf:"bytes,5,opt,name=oauth_redirect_url,json=oauthRedirectUrl,proto3" json:"oauth_redirect_url,omitempty"`
	OauthScopes           []string `protobuf:"bytes,6,rep,name=oauth_scopes,json=oauthScopes,proto3" json:"oauth_scopes,omitempty"`
	SessionSecret         string   `protobuf:"bytes,7,opt,name=session_secret,json=sessionSecret,proto3" json:"session_secret,omitempty"`
	// contains filtered or unexported fields
}

func (*UIFlags) Descriptor deprecated added in v1.4.0 

func (*UIFlags) Descriptor() ([]byte, []int)

Deprecated: Use UIFlags.ProtoReflect.Descriptor instead.

func (*UIFlags) GetOauthAuthorizationUrl added in v1.4.0 

func (x *UIFlags) GetOauthAuthorizationUrl() string

func (*UIFlags) GetOauthClientId added in v1.4.0 

func (x *UIFlags) GetOauthClientId() string

func (*UIFlags) GetOauthClientSecret added in v1.4.0 

func (x *UIFlags) GetOauthClientSecret() string

func (*UIFlags) GetOauthRedirectUrl added in v1.4.0 

func (x *UIFlags) GetOauthRedirectUrl() string

func (*UIFlags) GetOauthScopes added in v1.4.0 

func (x *UIFlags) GetOauthScopes() []string

func (*UIFlags) GetOauthTokenUrl added in v1.4.0 

func (x *UIFlags) GetOauthTokenUrl() string

func (*UIFlags) GetSessionSecret added in v1.4.0 

func (x *UIFlags) GetSessionSecret() string

func (*UIFlags) ProtoMessage added in v1.4.0 

func (*UIFlags) ProtoMessage()

func (*UIFlags) ProtoReflect added in v1.4.0 

func (x *UIFlags) ProtoReflect() protoreflect.Message

func (*UIFlags) Reset added in v1.4.0 

func (x *UIFlags) Reset()

func (*UIFlags) String added in v1.4.0 

func (x *UIFlags) String() string

func (*UIFlags) Validate added in v1.4.0 

func (this *UIFlags) Validate() error

type UnimplementedDatabaseServiceServer 

type UnimplementedDatabaseServiceServer struct {
}

UnimplementedDatabaseServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDatabaseServiceServer) AggregateConnections 

func (*UnimplementedDatabaseServiceServer) AggregateConnections(context.Context, *AggFilter) (*Number, error)

func (*UnimplementedDatabaseServiceServer) AggregateDocs 

func (*UnimplementedDatabaseServiceServer) AggregateDocs(context.Context, *AggFilter) (*Number, error)

func (*UnimplementedDatabaseServiceServer) Broadcast 

func (*UnimplementedDatabaseServiceServer) Broadcast(context.Context, *OutboundMessage) (*empty.Empty, error)

func (*UnimplementedDatabaseServiceServer) ConnectionsFrom 

func (*UnimplementedDatabaseServiceServer) ConnectionsFrom(context.Context, *ConnectFilter) (*Connections, error)

func (*UnimplementedDatabaseServiceServer) ConnectionsTo 

func (*UnimplementedDatabaseServiceServer) ConnectionsTo(context.Context, *ConnectFilter) (*Connections, error)

func (*UnimplementedDatabaseServiceServer) CreateConnection 

func (*UnimplementedDatabaseServiceServer) CreateConnection(context.Context, *ConnectionConstructor) (*Connection, error)

func (*UnimplementedDatabaseServiceServer) CreateConnections 

func (*UnimplementedDatabaseServiceServer) CreateConnections(context.Context, *ConnectionConstructors) (*Connections, error)

func (*UnimplementedDatabaseServiceServer) CreateDoc 

func (*UnimplementedDatabaseServiceServer) CreateDoc(context.Context, *DocConstructor) (*Doc, error)

func (*UnimplementedDatabaseServiceServer) CreateDocs 

func (*UnimplementedDatabaseServiceServer) CreateDocs(context.Context, *DocConstructors) (*Docs, error)

func (*UnimplementedDatabaseServiceServer) DelConnection 

func (*UnimplementedDatabaseServiceServer) DelConnection(context.Context, *Ref) (*empty.Empty, error)

func (*UnimplementedDatabaseServiceServer) DelConnections 

func (*UnimplementedDatabaseServiceServer) DelConnections(context.Context, *Filter) (*empty.Empty, error)

func (*UnimplementedDatabaseServiceServer) DelDoc 

func (*UnimplementedDatabaseServiceServer) DelDoc(context.Context, *Ref) (*empty.Empty, error)

func (*UnimplementedDatabaseServiceServer) DelDocs 

func (*UnimplementedDatabaseServiceServer) DelDocs(context.Context, *Filter) (*empty.Empty, error)

func (*UnimplementedDatabaseServiceServer) EditConnection 

func (*UnimplementedDatabaseServiceServer) EditConnection(context.Context, *Edit) (*Connection, error)

func (*UnimplementedDatabaseServiceServer) EditConnections 

func (*UnimplementedDatabaseServiceServer) EditConnections(context.Context, *EditFilter) (*Connections, error)

func (*UnimplementedDatabaseServiceServer) EditDoc 

func (*UnimplementedDatabaseServiceServer) EditDoc(context.Context, *Edit) (*Doc, error)

func (*UnimplementedDatabaseServiceServer) EditDocs 

func (*UnimplementedDatabaseServiceServer) EditDocs(context.Context, *EditFilter) (*Docs, error)

func (*UnimplementedDatabaseServiceServer) ExistsConnection 

func (*UnimplementedDatabaseServiceServer) ExistsConnection(context.Context, *ExistsFilter) (*Boolean, error)

func (*UnimplementedDatabaseServiceServer) ExistsDoc 

func (*UnimplementedDatabaseServiceServer) ExistsDoc(context.Context, *ExistsFilter) (*Boolean, error)

func (*UnimplementedDatabaseServiceServer) GetConnection 

func (*UnimplementedDatabaseServiceServer) GetConnection(context.Context, *Ref) (*Connection, error)

func (*UnimplementedDatabaseServiceServer) GetDoc 

func (*UnimplementedDatabaseServiceServer) GetDoc(context.Context, *Ref) (*Doc, error)

func (*UnimplementedDatabaseServiceServer) GetSchema 

func (*UnimplementedDatabaseServiceServer) GetSchema(context.Context, *empty.Empty) (*Schema, error)

func (*UnimplementedDatabaseServiceServer) HasConnection 

func (*UnimplementedDatabaseServiceServer) HasConnection(context.Context, *Ref) (*Boolean, error)

func (*UnimplementedDatabaseServiceServer) HasDoc 

func (*UnimplementedDatabaseServiceServer) HasDoc(context.Context, *Ref) (*Boolean, error)

func (*UnimplementedDatabaseServiceServer) Me 

func (*UnimplementedDatabaseServiceServer) Me(context.Context, *empty.Empty) (*Doc, error)

func (*UnimplementedDatabaseServiceServer) PushConnectionConstructors 

func (*UnimplementedDatabaseServiceServer) PushConnectionConstructors(DatabaseService_PushConnectionConstructorsServer) error

func (*UnimplementedDatabaseServiceServer) PushDocConstructors 

func (*UnimplementedDatabaseServiceServer) PushDocConstructors(DatabaseService_PushDocConstructorsServer) error

func (*UnimplementedDatabaseServiceServer) PutConnection 

func (*UnimplementedDatabaseServiceServer) PutConnection(context.Context, *Connection) (*Connection, error)

func (*UnimplementedDatabaseServiceServer) PutConnections 

func (*UnimplementedDatabaseServiceServer) PutConnections(context.Context, *Connections) (*Connections, error)

func (*UnimplementedDatabaseServiceServer) PutDoc 

func (*UnimplementedDatabaseServiceServer) PutDoc(context.Context, *Doc) (*Doc, error)

func (*UnimplementedDatabaseServiceServer) PutDocs 

func (*UnimplementedDatabaseServiceServer) PutDocs(context.Context, *Docs) (*Docs, error)

func (*UnimplementedDatabaseServiceServer) SearchAndConnect 

func (*UnimplementedDatabaseServiceServer) SearchAndConnect(context.Context, *SearchConnectFilter) (*Connections, error)

func (*UnimplementedDatabaseServiceServer) SearchAndConnectMe 

func (*UnimplementedDatabaseServiceServer) SearchAndConnectMe(context.Context, *SearchConnectMeFilter) (*Connections, error)

func (*UnimplementedDatabaseServiceServer) SearchConnections 

func (*UnimplementedDatabaseServiceServer) SearchConnections(context.Context, *Filter) (*Connections, error)

func (*UnimplementedDatabaseServiceServer) SearchDocs 

func (*UnimplementedDatabaseServiceServer) SearchDocs(context.Context, *Filter) (*Docs, error)

func (*UnimplementedDatabaseServiceServer) SeedConnections 

func (*UnimplementedDatabaseServiceServer) SeedConnections(DatabaseService_SeedConnectionsServer) error

func (*UnimplementedDatabaseServiceServer) SeedDocs 

func (*UnimplementedDatabaseServiceServer) SeedDocs(DatabaseService_SeedDocsServer) error

func (*UnimplementedDatabaseServiceServer) SetAuthorizers 

func (*UnimplementedDatabaseServiceServer) SetAuthorizers(context.Context, *Authorizers) (*empty.Empty, error)

func (*UnimplementedDatabaseServiceServer) SetConstraints 

func (*UnimplementedDatabaseServiceServer) SetConstraints(context.Context, *Constraints) (*empty.Empty, error)

func (*UnimplementedDatabaseServiceServer) SetIndexes 

func (*UnimplementedDatabaseServiceServer) SetIndexes(context.Context, *Indexes) (*empty.Empty, error)

func (*UnimplementedDatabaseServiceServer) SetTriggers 

func (*UnimplementedDatabaseServiceServer) SetTriggers(context.Context, *Triggers) (*empty.Empty, error)

func (*UnimplementedDatabaseServiceServer) Stream 

func (*UnimplementedDatabaseServiceServer) Stream(*StreamFilter, DatabaseService_StreamServer) error

func (*UnimplementedDatabaseServiceServer) Traverse 

func (*UnimplementedDatabaseServiceServer) Traverse(context.Context, *TraverseFilter) (*Traversals, error)

func (*UnimplementedDatabaseServiceServer) TraverseMe 

func (*UnimplementedDatabaseServiceServer) TraverseMe(context.Context, *TraverseMeFilter) (*Traversals, error)

type UnimplementedRaftServiceServer 

type UnimplementedRaftServiceServer struct {
}

UnimplementedRaftServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRaftServiceServer) ClusterState 

func (*UnimplementedRaftServiceServer) ClusterState(context.Context, *empty.Empty) (*RaftState, error)

func (*UnimplementedRaftServiceServer) JoinCluster 

func (*UnimplementedRaftServiceServer) JoinCluster(context.Context, *Peer) (*empty.Empty, error)

func (*UnimplementedRaftServiceServer) Ping 

func (*UnimplementedRaftServiceServer) Ping(context.Context, *empty.Empty) (*Pong, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.