Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterKesselCheckServiceHTTPServer(s *http.Server, srv KesselCheckServiceHTTPServer)
- func RegisterKesselCheckServiceServer(s grpc.ServiceRegistrar, srv KesselCheckServiceServer)
- func RegisterKesselLookupServiceServer(s grpc.ServiceRegistrar, srv KesselLookupServiceServer)
- func RegisterKesselTupleServiceHTTPServer(s *http.Server, srv KesselTupleServiceHTTPServer)
- func RegisterKesselTupleServiceServer(s grpc.ServiceRegistrar, srv KesselTupleServiceServer)
- type AcquireLockRequest
- func (*AcquireLockRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AcquireLockRequest) GetLockId() string
- func (*AcquireLockRequest) ProtoMessage()
- func (x *AcquireLockRequest) ProtoReflect() protoreflect.Message
- func (x *AcquireLockRequest) Reset()
- func (x *AcquireLockRequest) String() string
- type AcquireLockResponse
- func (*AcquireLockResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AcquireLockResponse) GetLockToken() string
- func (*AcquireLockResponse) ProtoMessage()
- func (x *AcquireLockResponse) ProtoReflect() protoreflect.Message
- func (x *AcquireLockResponse) Reset()
- func (x *AcquireLockResponse) String() string
- type CheckBulkRequest
- func (*CheckBulkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CheckBulkRequest) GetConsistency() *Consistency
- func (x *CheckBulkRequest) GetItems() []*CheckBulkRequestItem
- func (*CheckBulkRequest) ProtoMessage()
- func (x *CheckBulkRequest) ProtoReflect() protoreflect.Message
- func (x *CheckBulkRequest) Reset()
- func (x *CheckBulkRequest) String() string
- type CheckBulkRequestItem
- func (*CheckBulkRequestItem) Descriptor() ([]byte, []int)deprecated
- func (x *CheckBulkRequestItem) GetRelation() string
- func (x *CheckBulkRequestItem) GetResource() *ObjectReference
- func (x *CheckBulkRequestItem) GetSubject() *SubjectReference
- func (*CheckBulkRequestItem) ProtoMessage()
- func (x *CheckBulkRequestItem) ProtoReflect() protoreflect.Message
- func (x *CheckBulkRequestItem) Reset()
- func (x *CheckBulkRequestItem) String() string
- type CheckBulkResponse
- func (*CheckBulkResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckBulkResponse) GetConsistencyToken() *ConsistencyToken
- func (x *CheckBulkResponse) GetPairs() []*CheckBulkResponsePair
- func (*CheckBulkResponse) ProtoMessage()
- func (x *CheckBulkResponse) ProtoReflect() protoreflect.Message
- func (x *CheckBulkResponse) Reset()
- func (x *CheckBulkResponse) String() string
- type CheckBulkResponseItem
- func (*CheckBulkResponseItem) Descriptor() ([]byte, []int)deprecated
- func (x *CheckBulkResponseItem) GetAllowed() CheckBulkResponseItem_Allowed
- func (*CheckBulkResponseItem) ProtoMessage()
- func (x *CheckBulkResponseItem) ProtoReflect() protoreflect.Message
- func (x *CheckBulkResponseItem) Reset()
- func (x *CheckBulkResponseItem) String() string
- type CheckBulkResponseItem_Allowed
- func (CheckBulkResponseItem_Allowed) Descriptor() protoreflect.EnumDescriptor
- func (x CheckBulkResponseItem_Allowed) Enum() *CheckBulkResponseItem_Allowed
- func (CheckBulkResponseItem_Allowed) EnumDescriptor() ([]byte, []int)deprecated
- func (x CheckBulkResponseItem_Allowed) Number() protoreflect.EnumNumber
- func (x CheckBulkResponseItem_Allowed) String() string
- func (CheckBulkResponseItem_Allowed) Type() protoreflect.EnumType
- type CheckBulkResponsePair
- func (*CheckBulkResponsePair) Descriptor() ([]byte, []int)deprecated
- func (x *CheckBulkResponsePair) GetItem() *CheckBulkResponseItem
- func (x *CheckBulkResponsePair) GetRequest() *CheckBulkRequestItem
- func (*CheckBulkResponsePair) ProtoMessage()
- func (x *CheckBulkResponsePair) ProtoReflect() protoreflect.Message
- func (x *CheckBulkResponsePair) Reset()
- func (x *CheckBulkResponsePair) String() string
- type CheckForUpdateRequest
- func (*CheckForUpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CheckForUpdateRequest) GetRelation() string
- func (x *CheckForUpdateRequest) GetResource() *ObjectReference
- func (x *CheckForUpdateRequest) GetSubject() *SubjectReference
- func (*CheckForUpdateRequest) ProtoMessage()
- func (x *CheckForUpdateRequest) ProtoReflect() protoreflect.Message
- func (x *CheckForUpdateRequest) Reset()
- func (x *CheckForUpdateRequest) String() string
- type CheckForUpdateResponse
- func (*CheckForUpdateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckForUpdateResponse) GetAllowed() CheckForUpdateResponse_Allowed
- func (x *CheckForUpdateResponse) GetConsistencyToken() *ConsistencyToken
- func (*CheckForUpdateResponse) ProtoMessage()
- func (x *CheckForUpdateResponse) ProtoReflect() protoreflect.Message
- func (x *CheckForUpdateResponse) Reset()
- func (x *CheckForUpdateResponse) String() string
- type CheckForUpdateResponse_Allowed
- func (CheckForUpdateResponse_Allowed) Descriptor() protoreflect.EnumDescriptor
- func (x CheckForUpdateResponse_Allowed) Enum() *CheckForUpdateResponse_Allowed
- func (CheckForUpdateResponse_Allowed) EnumDescriptor() ([]byte, []int)deprecated
- func (x CheckForUpdateResponse_Allowed) Number() protoreflect.EnumNumber
- func (x CheckForUpdateResponse_Allowed) String() string
- func (CheckForUpdateResponse_Allowed) Type() protoreflect.EnumType
- type CheckRequest
- func (*CheckRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CheckRequest) GetConsistency() *Consistency
- func (x *CheckRequest) GetRelation() string
- func (x *CheckRequest) GetResource() *ObjectReference
- func (x *CheckRequest) GetSubject() *SubjectReference
- func (*CheckRequest) ProtoMessage()
- func (x *CheckRequest) ProtoReflect() protoreflect.Message
- func (x *CheckRequest) Reset()
- func (x *CheckRequest) String() string
- type CheckResponse
- func (*CheckResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckResponse) GetAllowed() CheckResponse_Allowed
- func (x *CheckResponse) GetConsistencyToken() *ConsistencyToken
- func (*CheckResponse) ProtoMessage()
- func (x *CheckResponse) ProtoReflect() protoreflect.Message
- func (x *CheckResponse) Reset()
- func (x *CheckResponse) String() string
- type CheckResponse_Allowed
- func (CheckResponse_Allowed) Descriptor() protoreflect.EnumDescriptor
- func (x CheckResponse_Allowed) Enum() *CheckResponse_Allowed
- func (CheckResponse_Allowed) EnumDescriptor() ([]byte, []int)deprecated
- func (x CheckResponse_Allowed) Number() protoreflect.EnumNumber
- func (x CheckResponse_Allowed) String() string
- func (CheckResponse_Allowed) Type() protoreflect.EnumType
- type Consistency
- func (*Consistency) Descriptor() ([]byte, []int)deprecated
- func (x *Consistency) GetAtLeastAsFresh() *ConsistencyToken
- func (x *Consistency) GetMinimizeLatency() bool
- func (x *Consistency) GetRequirement() isConsistency_Requirement
- func (*Consistency) ProtoMessage()
- func (x *Consistency) ProtoReflect() protoreflect.Message
- func (x *Consistency) Reset()
- func (x *Consistency) String() string
- type ConsistencyToken
- type Consistency_AtLeastAsFresh
- type Consistency_MinimizeLatency
- type CreateTuplesRequest
- func (*CreateTuplesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTuplesRequest) GetFencingCheck() *FencingCheck
- func (x *CreateTuplesRequest) GetTuples() []*Relationship
- func (x *CreateTuplesRequest) GetUpsert() bool
- func (*CreateTuplesRequest) ProtoMessage()
- func (x *CreateTuplesRequest) ProtoReflect() protoreflect.Message
- func (x *CreateTuplesRequest) Reset()
- func (x *CreateTuplesRequest) String() string
- type CreateTuplesResponse
- func (*CreateTuplesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTuplesResponse) GetConsistencyToken() *ConsistencyToken
- func (*CreateTuplesResponse) ProtoMessage()
- func (x *CreateTuplesResponse) ProtoReflect() protoreflect.Message
- func (x *CreateTuplesResponse) Reset()
- func (x *CreateTuplesResponse) String() string
- type DeleteTuplesRequest
- func (*DeleteTuplesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteTuplesRequest) GetFencingCheck() *FencingCheck
- func (x *DeleteTuplesRequest) GetFilter() *RelationTupleFilter
- func (*DeleteTuplesRequest) ProtoMessage()
- func (x *DeleteTuplesRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteTuplesRequest) Reset()
- func (x *DeleteTuplesRequest) String() string
- type DeleteTuplesResponse
- func (*DeleteTuplesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteTuplesResponse) GetConsistencyToken() *ConsistencyToken
- func (*DeleteTuplesResponse) ProtoMessage()
- func (x *DeleteTuplesResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteTuplesResponse) Reset()
- func (x *DeleteTuplesResponse) String() string
- type FencingCheck
- func (*FencingCheck) Descriptor() ([]byte, []int)deprecated
- func (x *FencingCheck) GetLockId() string
- func (x *FencingCheck) GetLockToken() string
- func (*FencingCheck) ProtoMessage()
- func (x *FencingCheck) ProtoReflect() protoreflect.Message
- func (x *FencingCheck) Reset()
- func (x *FencingCheck) String() string
- type ImportBulkTuplesRequest
- func (*ImportBulkTuplesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ImportBulkTuplesRequest) GetTuples() []*Relationship
- func (*ImportBulkTuplesRequest) ProtoMessage()
- func (x *ImportBulkTuplesRequest) ProtoReflect() protoreflect.Message
- func (x *ImportBulkTuplesRequest) Reset()
- func (x *ImportBulkTuplesRequest) String() string
- type ImportBulkTuplesResponse
- func (*ImportBulkTuplesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ImportBulkTuplesResponse) GetNumImported() uint64
- func (*ImportBulkTuplesResponse) ProtoMessage()
- func (x *ImportBulkTuplesResponse) ProtoReflect() protoreflect.Message
- func (x *ImportBulkTuplesResponse) Reset()
- func (x *ImportBulkTuplesResponse) String() string
- type KesselCheckServiceClient
- type KesselCheckServiceHTTPClient
- type KesselCheckServiceHTTPClientImpl
- func (c *KesselCheckServiceHTTPClientImpl) Check(ctx context.Context, in *CheckRequest, opts ...http.CallOption) (*CheckResponse, error)
- func (c *KesselCheckServiceHTTPClientImpl) CheckBulk(ctx context.Context, in *CheckBulkRequest, opts ...http.CallOption) (*CheckBulkResponse, error)
- func (c *KesselCheckServiceHTTPClientImpl) CheckForUpdate(ctx context.Context, in *CheckForUpdateRequest, opts ...http.CallOption) (*CheckForUpdateResponse, error)
- type KesselCheckServiceHTTPServer
- type KesselCheckServiceServer
- type KesselLookupServiceClient
- type KesselLookupServiceServer
- type KesselLookupService_LookupResourcesClient
- type KesselLookupService_LookupResourcesServer
- type KesselLookupService_LookupSubjectsClient
- type KesselLookupService_LookupSubjectsServer
- type KesselTupleServiceClient
- type KesselTupleServiceHTTPClient
- type KesselTupleServiceHTTPClientImpl
- func (c *KesselTupleServiceHTTPClientImpl) AcquireLock(ctx context.Context, in *AcquireLockRequest, opts ...http.CallOption) (*AcquireLockResponse, error)
- func (c *KesselTupleServiceHTTPClientImpl) CreateTuples(ctx context.Context, in *CreateTuplesRequest, opts ...http.CallOption) (*CreateTuplesResponse, error)
- func (c *KesselTupleServiceHTTPClientImpl) DeleteTuples(ctx context.Context, in *DeleteTuplesRequest, opts ...http.CallOption) (*DeleteTuplesResponse, error)
- type KesselTupleServiceHTTPServer
- type KesselTupleServiceServer
- type KesselTupleService_ImportBulkTuplesClient
- type KesselTupleService_ImportBulkTuplesServer
- type KesselTupleService_ReadTuplesClient
- type KesselTupleService_ReadTuplesServer
- type LookupResourcesRequest
- func (*LookupResourcesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookupResourcesRequest) GetConsistency() *Consistency
- func (x *LookupResourcesRequest) GetPagination() *RequestPagination
- func (x *LookupResourcesRequest) GetRelation() string
- func (x *LookupResourcesRequest) GetResourceType() *ObjectType
- func (x *LookupResourcesRequest) GetSubject() *SubjectReference
- func (*LookupResourcesRequest) ProtoMessage()
- func (x *LookupResourcesRequest) ProtoReflect() protoreflect.Message
- func (x *LookupResourcesRequest) Reset()
- func (x *LookupResourcesRequest) String() string
- type LookupResourcesResponse
- func (*LookupResourcesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LookupResourcesResponse) GetConsistencyToken() *ConsistencyToken
- func (x *LookupResourcesResponse) GetPagination() *ResponsePagination
- func (x *LookupResourcesResponse) GetResource() *ObjectReference
- func (*LookupResourcesResponse) ProtoMessage()
- func (x *LookupResourcesResponse) ProtoReflect() protoreflect.Message
- func (x *LookupResourcesResponse) Reset()
- func (x *LookupResourcesResponse) String() string
- type LookupSubjectsRequest
- func (*LookupSubjectsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookupSubjectsRequest) GetConsistency() *Consistency
- func (x *LookupSubjectsRequest) GetPagination() *RequestPagination
- func (x *LookupSubjectsRequest) GetRelation() string
- func (x *LookupSubjectsRequest) GetResource() *ObjectReference
- func (x *LookupSubjectsRequest) GetSubjectRelation() string
- func (x *LookupSubjectsRequest) GetSubjectType() *ObjectType
- func (*LookupSubjectsRequest) ProtoMessage()
- func (x *LookupSubjectsRequest) ProtoReflect() protoreflect.Message
- func (x *LookupSubjectsRequest) Reset()
- func (x *LookupSubjectsRequest) String() string
- type LookupSubjectsResponse
- func (*LookupSubjectsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LookupSubjectsResponse) GetConsistencyToken() *ConsistencyToken
- func (x *LookupSubjectsResponse) GetPagination() *ResponsePagination
- func (x *LookupSubjectsResponse) GetSubject() *SubjectReference
- func (*LookupSubjectsResponse) ProtoMessage()
- func (x *LookupSubjectsResponse) ProtoReflect() protoreflect.Message
- func (x *LookupSubjectsResponse) Reset()
- func (x *LookupSubjectsResponse) String() string
- type ObjectReference
- func (*ObjectReference) Descriptor() ([]byte, []int)deprecated
- func (x *ObjectReference) GetId() string
- func (x *ObjectReference) GetType() *ObjectType
- func (*ObjectReference) ProtoMessage()
- func (x *ObjectReference) ProtoReflect() protoreflect.Message
- func (x *ObjectReference) Reset()
- func (x *ObjectReference) String() string
- type ObjectType
- type ReadTuplesRequest
- func (*ReadTuplesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadTuplesRequest) GetConsistency() *Consistency
- func (x *ReadTuplesRequest) GetFilter() *RelationTupleFilter
- func (x *ReadTuplesRequest) GetPagination() *RequestPagination
- func (*ReadTuplesRequest) ProtoMessage()
- func (x *ReadTuplesRequest) ProtoReflect() protoreflect.Message
- func (x *ReadTuplesRequest) Reset()
- func (x *ReadTuplesRequest) String() string
- type ReadTuplesResponse
- func (*ReadTuplesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadTuplesResponse) GetConsistencyToken() *ConsistencyToken
- func (x *ReadTuplesResponse) GetPagination() *ResponsePagination
- func (x *ReadTuplesResponse) GetTuple() *Relationship
- func (*ReadTuplesResponse) ProtoMessage()
- func (x *ReadTuplesResponse) ProtoReflect() protoreflect.Message
- func (x *ReadTuplesResponse) Reset()
- func (x *ReadTuplesResponse) String() string
- type RelationTupleFilter
- func (*RelationTupleFilter) Descriptor() ([]byte, []int)deprecated
- func (x *RelationTupleFilter) GetRelation() string
- func (x *RelationTupleFilter) GetResourceId() string
- func (x *RelationTupleFilter) GetResourceNamespace() string
- func (x *RelationTupleFilter) GetResourceType() string
- func (x *RelationTupleFilter) GetSubjectFilter() *SubjectFilter
- func (*RelationTupleFilter) ProtoMessage()
- func (x *RelationTupleFilter) ProtoReflect() protoreflect.Message
- func (x *RelationTupleFilter) Reset()
- func (x *RelationTupleFilter) String() string
- type Relationship
- func (*Relationship) Descriptor() ([]byte, []int)deprecated
- func (x *Relationship) GetRelation() string
- func (x *Relationship) GetResource() *ObjectReference
- func (x *Relationship) GetSubject() *SubjectReference
- func (*Relationship) ProtoMessage()
- func (x *Relationship) ProtoReflect() protoreflect.Message
- func (x *Relationship) Reset()
- func (x *Relationship) String() string
- type RequestPagination
- func (*RequestPagination) Descriptor() ([]byte, []int)deprecated
- func (x *RequestPagination) GetContinuationToken() string
- func (x *RequestPagination) GetLimit() uint32
- func (*RequestPagination) ProtoMessage()
- func (x *RequestPagination) ProtoReflect() protoreflect.Message
- func (x *RequestPagination) Reset()
- func (x *RequestPagination) String() string
- type ResponsePagination
- func (*ResponsePagination) Descriptor() ([]byte, []int)deprecated
- func (x *ResponsePagination) GetContinuationToken() string
- func (*ResponsePagination) ProtoMessage()
- func (x *ResponsePagination) ProtoReflect() protoreflect.Message
- func (x *ResponsePagination) Reset()
- func (x *ResponsePagination) String() string
- type SubjectFilter
- func (*SubjectFilter) Descriptor() ([]byte, []int)deprecated
- func (x *SubjectFilter) GetRelation() string
- func (x *SubjectFilter) GetSubjectId() string
- func (x *SubjectFilter) GetSubjectNamespace() string
- func (x *SubjectFilter) GetSubjectType() string
- func (*SubjectFilter) ProtoMessage()
- func (x *SubjectFilter) ProtoReflect() protoreflect.Message
- func (x *SubjectFilter) Reset()
- func (x *SubjectFilter) String() string
- type SubjectReference
- func (*SubjectReference) Descriptor() ([]byte, []int)deprecated
- func (x *SubjectReference) GetRelation() string
- func (x *SubjectReference) GetSubject() *ObjectReference
- func (*SubjectReference) ProtoMessage()
- func (x *SubjectReference) ProtoReflect() protoreflect.Message
- func (x *SubjectReference) Reset()
- func (x *SubjectReference) String() string
- type UnimplementedKesselCheckServiceServer
- func (UnimplementedKesselCheckServiceServer) Check(context.Context, *CheckRequest) (*CheckResponse, error)
- func (UnimplementedKesselCheckServiceServer) CheckBulk(context.Context, *CheckBulkRequest) (*CheckBulkResponse, error)
- func (UnimplementedKesselCheckServiceServer) CheckForUpdate(context.Context, *CheckForUpdateRequest) (*CheckForUpdateResponse, error)
- type UnimplementedKesselLookupServiceServer
- type UnimplementedKesselTupleServiceServer
- func (UnimplementedKesselTupleServiceServer) AcquireLock(context.Context, *AcquireLockRequest) (*AcquireLockResponse, error)
- func (UnimplementedKesselTupleServiceServer) CreateTuples(context.Context, *CreateTuplesRequest) (*CreateTuplesResponse, error)
- func (UnimplementedKesselTupleServiceServer) DeleteTuples(context.Context, *DeleteTuplesRequest) (*DeleteTuplesResponse, error)
- func (UnimplementedKesselTupleServiceServer) ImportBulkTuples(grpc.ClientStreamingServer[ImportBulkTuplesRequest, ImportBulkTuplesResponse]) error
- func (UnimplementedKesselTupleServiceServer) ReadTuples(*ReadTuplesRequest, grpc.ServerStreamingServer[ReadTuplesResponse]) error
- type UnsafeKesselCheckServiceServer
- type UnsafeKesselLookupServiceServer
- type UnsafeKesselTupleServiceServer
Constants ¶
const ( KesselCheckService_Check_FullMethodName = "/kessel.relations.v1beta1.KesselCheckService/Check" KesselCheckService_CheckForUpdate_FullMethodName = "/kessel.relations.v1beta1.KesselCheckService/CheckForUpdate" KesselCheckService_CheckBulk_FullMethodName = "/kessel.relations.v1beta1.KesselCheckService/CheckBulk" )
const ( KesselLookupService_LookupSubjects_FullMethodName = "/kessel.relations.v1beta1.KesselLookupService/LookupSubjects" KesselLookupService_LookupResources_FullMethodName = "/kessel.relations.v1beta1.KesselLookupService/LookupResources" )
const ( KesselTupleService_CreateTuples_FullMethodName = "/kessel.relations.v1beta1.KesselTupleService/CreateTuples" KesselTupleService_ReadTuples_FullMethodName = "/kessel.relations.v1beta1.KesselTupleService/ReadTuples" KesselTupleService_DeleteTuples_FullMethodName = "/kessel.relations.v1beta1.KesselTupleService/DeleteTuples" KesselTupleService_ImportBulkTuples_FullMethodName = "/kessel.relations.v1beta1.KesselTupleService/ImportBulkTuples" KesselTupleService_AcquireLock_FullMethodName = "/kessel.relations.v1beta1.KesselTupleService/AcquireLock" )
const OperationKesselCheckServiceCheck = "/kessel.relations.v1beta1.KesselCheckService/Check"
const OperationKesselCheckServiceCheckBulk = "/kessel.relations.v1beta1.KesselCheckService/CheckBulk"
const OperationKesselCheckServiceCheckForUpdate = "/kessel.relations.v1beta1.KesselCheckService/CheckForUpdate"
const OperationKesselTupleServiceAcquireLock = "/kessel.relations.v1beta1.KesselTupleService/AcquireLock"
const OperationKesselTupleServiceCreateTuples = "/kessel.relations.v1beta1.KesselTupleService/CreateTuples"
const OperationKesselTupleServiceDeleteTuples = "/kessel.relations.v1beta1.KesselTupleService/DeleteTuples"
Variables ¶
var ( CheckResponse_Allowed_name = map[int32]string{ 0: "ALLOWED_UNSPECIFIED", 1: "ALLOWED_TRUE", 2: "ALLOWED_FALSE", } CheckResponse_Allowed_value = map[string]int32{ "ALLOWED_UNSPECIFIED": 0, "ALLOWED_TRUE": 1, "ALLOWED_FALSE": 2, } )
Enum value maps for CheckResponse_Allowed.
var ( CheckForUpdateResponse_Allowed_name = map[int32]string{ 0: "ALLOWED_UNSPECIFIED", 1: "ALLOWED_TRUE", 2: "ALLOWED_FALSE", } CheckForUpdateResponse_Allowed_value = map[string]int32{ "ALLOWED_UNSPECIFIED": 0, "ALLOWED_TRUE": 1, "ALLOWED_FALSE": 2, } )
Enum value maps for CheckForUpdateResponse_Allowed.
var ( CheckBulkResponseItem_Allowed_name = map[int32]string{ 0: "ALLOWED_UNSPECIFIED", 1: "ALLOWED_TRUE", 2: "ALLOWED_FALSE", } CheckBulkResponseItem_Allowed_value = map[string]int32{ "ALLOWED_UNSPECIFIED": 0, "ALLOWED_TRUE": 1, "ALLOWED_FALSE": 2, } )
Enum value maps for CheckBulkResponseItem_Allowed.
var File_kessel_relations_v1beta1_check_proto protoreflect.FileDescriptor
var File_kessel_relations_v1beta1_common_proto protoreflect.FileDescriptor
var File_kessel_relations_v1beta1_lookup_proto protoreflect.FileDescriptor
var File_kessel_relations_v1beta1_relation_tuples_proto protoreflect.FileDescriptor
var KesselCheckService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "kessel.relations.v1beta1.KesselCheckService", HandlerType: (*KesselCheckServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Check", Handler: _KesselCheckService_Check_Handler, }, { MethodName: "CheckForUpdate", Handler: _KesselCheckService_CheckForUpdate_Handler, }, { MethodName: "CheckBulk", Handler: _KesselCheckService_CheckBulk_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "kessel/relations/v1beta1/check.proto", }
KesselCheckService_ServiceDesc is the grpc.ServiceDesc for KesselCheckService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var KesselLookupService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "kessel.relations.v1beta1.KesselLookupService", HandlerType: (*KesselLookupServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "LookupSubjects", Handler: _KesselLookupService_LookupSubjects_Handler, ServerStreams: true, }, { StreamName: "LookupResources", Handler: _KesselLookupService_LookupResources_Handler, ServerStreams: true, }, }, Metadata: "kessel/relations/v1beta1/lookup.proto", }
KesselLookupService_ServiceDesc is the grpc.ServiceDesc for KesselLookupService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var KesselTupleService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "kessel.relations.v1beta1.KesselTupleService", HandlerType: (*KesselTupleServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateTuples", Handler: _KesselTupleService_CreateTuples_Handler, }, { MethodName: "DeleteTuples", Handler: _KesselTupleService_DeleteTuples_Handler, }, { MethodName: "AcquireLock", Handler: _KesselTupleService_AcquireLock_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ReadTuples", Handler: _KesselTupleService_ReadTuples_Handler, ServerStreams: true, }, { StreamName: "ImportBulkTuples", Handler: _KesselTupleService_ImportBulkTuples_Handler, ClientStreams: true, }, }, Metadata: "kessel/relations/v1beta1/relation_tuples.proto", }
KesselTupleService_ServiceDesc is the grpc.ServiceDesc for KesselTupleService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterKesselCheckServiceHTTPServer ¶
func RegisterKesselCheckServiceHTTPServer(s *http.Server, srv KesselCheckServiceHTTPServer)
func RegisterKesselCheckServiceServer ¶
func RegisterKesselCheckServiceServer(s grpc.ServiceRegistrar, srv KesselCheckServiceServer)
func RegisterKesselLookupServiceServer ¶
func RegisterKesselLookupServiceServer(s grpc.ServiceRegistrar, srv KesselLookupServiceServer)
func RegisterKesselTupleServiceHTTPServer ¶
func RegisterKesselTupleServiceHTTPServer(s *http.Server, srv KesselTupleServiceHTTPServer)
func RegisterKesselTupleServiceServer ¶
func RegisterKesselTupleServiceServer(s grpc.ServiceRegistrar, srv KesselTupleServiceServer)
Types ¶
type AcquireLockRequest ¶
type AcquireLockRequest struct {
LockId string `protobuf:"bytes,1,opt,name=lock_id,json=lockId,proto3" json:"lock_id,omitempty"`
// contains filtered or unexported fields
}
func (*AcquireLockRequest) Descriptor
deprecated
func (*AcquireLockRequest) Descriptor() ([]byte, []int)
Deprecated: Use AcquireLockRequest.ProtoReflect.Descriptor instead.
func (*AcquireLockRequest) GetLockId ¶
func (x *AcquireLockRequest) GetLockId() string
func (*AcquireLockRequest) ProtoMessage ¶
func (*AcquireLockRequest) ProtoMessage()
func (*AcquireLockRequest) ProtoReflect ¶
func (x *AcquireLockRequest) ProtoReflect() protoreflect.Message
func (*AcquireLockRequest) Reset ¶
func (x *AcquireLockRequest) Reset()
func (*AcquireLockRequest) String ¶
func (x *AcquireLockRequest) String() string
type AcquireLockResponse ¶
type AcquireLockResponse struct {
LockToken string `protobuf:"bytes,1,opt,name=lock_token,json=lockToken,proto3" json:"lock_token,omitempty"`
// contains filtered or unexported fields
}
func (*AcquireLockResponse) Descriptor
deprecated
func (*AcquireLockResponse) Descriptor() ([]byte, []int)
Deprecated: Use AcquireLockResponse.ProtoReflect.Descriptor instead.
func (*AcquireLockResponse) GetLockToken ¶
func (x *AcquireLockResponse) GetLockToken() string
func (*AcquireLockResponse) ProtoMessage ¶
func (*AcquireLockResponse) ProtoMessage()
func (*AcquireLockResponse) ProtoReflect ¶
func (x *AcquireLockResponse) ProtoReflect() protoreflect.Message
func (*AcquireLockResponse) Reset ¶
func (x *AcquireLockResponse) Reset()
func (*AcquireLockResponse) String ¶
func (x *AcquireLockResponse) String() string
type CheckBulkRequest ¶
type CheckBulkRequest struct {
Items []*CheckBulkRequestItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
Consistency *Consistency `protobuf:"bytes,2,opt,name=consistency,proto3" json:"consistency,omitempty"`
// contains filtered or unexported fields
}
func (*CheckBulkRequest) Descriptor
deprecated
func (*CheckBulkRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckBulkRequest.ProtoReflect.Descriptor instead.
func (*CheckBulkRequest) GetConsistency ¶
func (x *CheckBulkRequest) GetConsistency() *Consistency
func (*CheckBulkRequest) GetItems ¶
func (x *CheckBulkRequest) GetItems() []*CheckBulkRequestItem
func (*CheckBulkRequest) ProtoMessage ¶
func (*CheckBulkRequest) ProtoMessage()
func (*CheckBulkRequest) ProtoReflect ¶
func (x *CheckBulkRequest) ProtoReflect() protoreflect.Message
func (*CheckBulkRequest) Reset ¶
func (x *CheckBulkRequest) Reset()
func (*CheckBulkRequest) String ¶
func (x *CheckBulkRequest) String() string
type CheckBulkRequestItem ¶
type CheckBulkRequestItem struct {
Resource *ObjectReference `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
Relation string `protobuf:"bytes,2,opt,name=relation,proto3" json:"relation,omitempty"`
Subject *SubjectReference `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"`
// contains filtered or unexported fields
}
func (*CheckBulkRequestItem) Descriptor
deprecated
func (*CheckBulkRequestItem) Descriptor() ([]byte, []int)
Deprecated: Use CheckBulkRequestItem.ProtoReflect.Descriptor instead.
func (*CheckBulkRequestItem) GetRelation ¶
func (x *CheckBulkRequestItem) GetRelation() string
func (*CheckBulkRequestItem) GetResource ¶
func (x *CheckBulkRequestItem) GetResource() *ObjectReference
func (*CheckBulkRequestItem) GetSubject ¶
func (x *CheckBulkRequestItem) GetSubject() *SubjectReference
func (*CheckBulkRequestItem) ProtoMessage ¶
func (*CheckBulkRequestItem) ProtoMessage()
func (*CheckBulkRequestItem) ProtoReflect ¶
func (x *CheckBulkRequestItem) ProtoReflect() protoreflect.Message
func (*CheckBulkRequestItem) Reset ¶
func (x *CheckBulkRequestItem) Reset()
func (*CheckBulkRequestItem) String ¶
func (x *CheckBulkRequestItem) String() string
type CheckBulkResponse ¶
type CheckBulkResponse struct {
Pairs []*CheckBulkResponsePair `protobuf:"bytes,1,rep,name=pairs,proto3" json:"pairs,omitempty"`
ConsistencyToken *ConsistencyToken `protobuf:"bytes,2,opt,name=consistency_token,json=consistencyToken,proto3" json:"consistency_token,omitempty"`
// contains filtered or unexported fields
}
func (*CheckBulkResponse) Descriptor
deprecated
func (*CheckBulkResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckBulkResponse.ProtoReflect.Descriptor instead.
func (*CheckBulkResponse) GetConsistencyToken ¶
func (x *CheckBulkResponse) GetConsistencyToken() *ConsistencyToken
func (*CheckBulkResponse) GetPairs ¶
func (x *CheckBulkResponse) GetPairs() []*CheckBulkResponsePair
func (*CheckBulkResponse) ProtoMessage ¶
func (*CheckBulkResponse) ProtoMessage()
func (*CheckBulkResponse) ProtoReflect ¶
func (x *CheckBulkResponse) ProtoReflect() protoreflect.Message
func (*CheckBulkResponse) Reset ¶
func (x *CheckBulkResponse) Reset()
func (*CheckBulkResponse) String ¶
func (x *CheckBulkResponse) String() string
type CheckBulkResponseItem ¶
type CheckBulkResponseItem struct {
Allowed CheckBulkResponseItem_Allowed `` /* 128-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*CheckBulkResponseItem) Descriptor
deprecated
func (*CheckBulkResponseItem) Descriptor() ([]byte, []int)
Deprecated: Use CheckBulkResponseItem.ProtoReflect.Descriptor instead.
func (*CheckBulkResponseItem) GetAllowed ¶
func (x *CheckBulkResponseItem) GetAllowed() CheckBulkResponseItem_Allowed
func (*CheckBulkResponseItem) ProtoMessage ¶
func (*CheckBulkResponseItem) ProtoMessage()
func (*CheckBulkResponseItem) ProtoReflect ¶
func (x *CheckBulkResponseItem) ProtoReflect() protoreflect.Message
func (*CheckBulkResponseItem) Reset ¶
func (x *CheckBulkResponseItem) Reset()
func (*CheckBulkResponseItem) String ¶
func (x *CheckBulkResponseItem) String() string
type CheckBulkResponseItem_Allowed ¶
type CheckBulkResponseItem_Allowed int32
const ( CheckBulkResponseItem_ALLOWED_UNSPECIFIED CheckBulkResponseItem_Allowed = 0 CheckBulkResponseItem_ALLOWED_TRUE CheckBulkResponseItem_Allowed = 1 CheckBulkResponseItem_ALLOWED_FALSE CheckBulkResponseItem_Allowed = 2 // e.g. ALLOWED_CONDITIONAL = 3; )
func (CheckBulkResponseItem_Allowed) Descriptor ¶
func (CheckBulkResponseItem_Allowed) Descriptor() protoreflect.EnumDescriptor
func (CheckBulkResponseItem_Allowed) Enum ¶
func (x CheckBulkResponseItem_Allowed) Enum() *CheckBulkResponseItem_Allowed
func (CheckBulkResponseItem_Allowed) EnumDescriptor
deprecated
func (CheckBulkResponseItem_Allowed) EnumDescriptor() ([]byte, []int)
Deprecated: Use CheckBulkResponseItem_Allowed.Descriptor instead.
func (CheckBulkResponseItem_Allowed) Number ¶
func (x CheckBulkResponseItem_Allowed) Number() protoreflect.EnumNumber
func (CheckBulkResponseItem_Allowed) String ¶
func (x CheckBulkResponseItem_Allowed) String() string
func (CheckBulkResponseItem_Allowed) Type ¶
func (CheckBulkResponseItem_Allowed) Type() protoreflect.EnumType
type CheckBulkResponsePair ¶
type CheckBulkResponsePair struct {
Request *CheckBulkRequestItem `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
Item *CheckBulkResponseItem `protobuf:"bytes,2,opt,name=item,proto3" json:"item,omitempty"`
// contains filtered or unexported fields
}
func (*CheckBulkResponsePair) Descriptor
deprecated
func (*CheckBulkResponsePair) Descriptor() ([]byte, []int)
Deprecated: Use CheckBulkResponsePair.ProtoReflect.Descriptor instead.
func (*CheckBulkResponsePair) GetItem ¶
func (x *CheckBulkResponsePair) GetItem() *CheckBulkResponseItem
func (*CheckBulkResponsePair) GetRequest ¶
func (x *CheckBulkResponsePair) GetRequest() *CheckBulkRequestItem
func (*CheckBulkResponsePair) ProtoMessage ¶
func (*CheckBulkResponsePair) ProtoMessage()
func (*CheckBulkResponsePair) ProtoReflect ¶
func (x *CheckBulkResponsePair) ProtoReflect() protoreflect.Message
func (*CheckBulkResponsePair) Reset ¶
func (x *CheckBulkResponsePair) Reset()
func (*CheckBulkResponsePair) String ¶
func (x *CheckBulkResponsePair) String() string
type CheckForUpdateRequest ¶
type CheckForUpdateRequest struct {
Resource *ObjectReference `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
Relation string `protobuf:"bytes,2,opt,name=relation,proto3" json:"relation,omitempty"`
Subject *SubjectReference `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"`
// contains filtered or unexported fields
}
func (*CheckForUpdateRequest) Descriptor
deprecated
func (*CheckForUpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckForUpdateRequest.ProtoReflect.Descriptor instead.
func (*CheckForUpdateRequest) GetRelation ¶
func (x *CheckForUpdateRequest) GetRelation() string
func (*CheckForUpdateRequest) GetResource ¶
func (x *CheckForUpdateRequest) GetResource() *ObjectReference
func (*CheckForUpdateRequest) GetSubject ¶
func (x *CheckForUpdateRequest) GetSubject() *SubjectReference
func (*CheckForUpdateRequest) ProtoMessage ¶
func (*CheckForUpdateRequest) ProtoMessage()
func (*CheckForUpdateRequest) ProtoReflect ¶
func (x *CheckForUpdateRequest) ProtoReflect() protoreflect.Message
func (*CheckForUpdateRequest) Reset ¶
func (x *CheckForUpdateRequest) Reset()
func (*CheckForUpdateRequest) String ¶
func (x *CheckForUpdateRequest) String() string
type CheckForUpdateResponse ¶
type CheckForUpdateResponse struct {
Allowed CheckForUpdateResponse_Allowed `` /* 129-byte string literal not displayed */
ConsistencyToken *ConsistencyToken `protobuf:"bytes,2,opt,name=consistency_token,json=consistencyToken,proto3" json:"consistency_token,omitempty"`
// contains filtered or unexported fields
}
func (*CheckForUpdateResponse) Descriptor
deprecated
func (*CheckForUpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckForUpdateResponse.ProtoReflect.Descriptor instead.
func (*CheckForUpdateResponse) GetAllowed ¶
func (x *CheckForUpdateResponse) GetAllowed() CheckForUpdateResponse_Allowed
func (*CheckForUpdateResponse) GetConsistencyToken ¶
func (x *CheckForUpdateResponse) GetConsistencyToken() *ConsistencyToken
func (*CheckForUpdateResponse) ProtoMessage ¶
func (*CheckForUpdateResponse) ProtoMessage()
func (*CheckForUpdateResponse) ProtoReflect ¶
func (x *CheckForUpdateResponse) ProtoReflect() protoreflect.Message
func (*CheckForUpdateResponse) Reset ¶
func (x *CheckForUpdateResponse) Reset()
func (*CheckForUpdateResponse) String ¶
func (x *CheckForUpdateResponse) String() string
type CheckForUpdateResponse_Allowed ¶
type CheckForUpdateResponse_Allowed int32
const ( CheckForUpdateResponse_ALLOWED_UNSPECIFIED CheckForUpdateResponse_Allowed = 0 CheckForUpdateResponse_ALLOWED_TRUE CheckForUpdateResponse_Allowed = 1 CheckForUpdateResponse_ALLOWED_FALSE CheckForUpdateResponse_Allowed = 2 // e.g. ALLOWED_CONDITIONAL = 3; )
func (CheckForUpdateResponse_Allowed) Descriptor ¶
func (CheckForUpdateResponse_Allowed) Descriptor() protoreflect.EnumDescriptor
func (CheckForUpdateResponse_Allowed) Enum ¶
func (x CheckForUpdateResponse_Allowed) Enum() *CheckForUpdateResponse_Allowed
func (CheckForUpdateResponse_Allowed) EnumDescriptor
deprecated
func (CheckForUpdateResponse_Allowed) EnumDescriptor() ([]byte, []int)
Deprecated: Use CheckForUpdateResponse_Allowed.Descriptor instead.
func (CheckForUpdateResponse_Allowed) Number ¶
func (x CheckForUpdateResponse_Allowed) Number() protoreflect.EnumNumber
func (CheckForUpdateResponse_Allowed) String ¶
func (x CheckForUpdateResponse_Allowed) String() string
func (CheckForUpdateResponse_Allowed) Type ¶
func (CheckForUpdateResponse_Allowed) Type() protoreflect.EnumType
type CheckRequest ¶
type CheckRequest struct {
Resource *ObjectReference `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
Relation string `protobuf:"bytes,2,opt,name=relation,proto3" json:"relation,omitempty"`
Subject *SubjectReference `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"`
Consistency *Consistency `protobuf:"bytes,4,opt,name=consistency,proto3" json:"consistency,omitempty"`
// contains filtered or unexported fields
}
func (*CheckRequest) Descriptor
deprecated
func (*CheckRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckRequest.ProtoReflect.Descriptor instead.
func (*CheckRequest) GetConsistency ¶
func (x *CheckRequest) GetConsistency() *Consistency
func (*CheckRequest) GetRelation ¶
func (x *CheckRequest) GetRelation() string
func (*CheckRequest) GetResource ¶
func (x *CheckRequest) GetResource() *ObjectReference
func (*CheckRequest) GetSubject ¶
func (x *CheckRequest) GetSubject() *SubjectReference
func (*CheckRequest) ProtoMessage ¶
func (*CheckRequest) ProtoMessage()
func (*CheckRequest) ProtoReflect ¶
func (x *CheckRequest) ProtoReflect() protoreflect.Message
func (*CheckRequest) Reset ¶
func (x *CheckRequest) Reset()
func (*CheckRequest) String ¶
func (x *CheckRequest) String() string
type CheckResponse ¶
type CheckResponse struct {
Allowed CheckResponse_Allowed `protobuf:"varint,1,opt,name=allowed,proto3,enum=kessel.relations.v1beta1.CheckResponse_Allowed" json:"allowed,omitempty"`
ConsistencyToken *ConsistencyToken `protobuf:"bytes,2,opt,name=consistency_token,json=consistencyToken,proto3" json:"consistency_token,omitempty"`
// contains filtered or unexported fields
}
func (*CheckResponse) Descriptor
deprecated
func (*CheckResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckResponse.ProtoReflect.Descriptor instead.
func (*CheckResponse) GetAllowed ¶
func (x *CheckResponse) GetAllowed() CheckResponse_Allowed
func (*CheckResponse) GetConsistencyToken ¶
func (x *CheckResponse) GetConsistencyToken() *ConsistencyToken
func (*CheckResponse) ProtoMessage ¶
func (*CheckResponse) ProtoMessage()
func (*CheckResponse) ProtoReflect ¶
func (x *CheckResponse) ProtoReflect() protoreflect.Message
func (*CheckResponse) Reset ¶
func (x *CheckResponse) Reset()
func (*CheckResponse) String ¶
func (x *CheckResponse) String() string
type CheckResponse_Allowed ¶
type CheckResponse_Allowed int32
const ( CheckResponse_ALLOWED_UNSPECIFIED CheckResponse_Allowed = 0 CheckResponse_ALLOWED_TRUE CheckResponse_Allowed = 1 CheckResponse_ALLOWED_FALSE CheckResponse_Allowed = 2 // e.g. ALLOWED_CONDITIONAL = 3; )
func (CheckResponse_Allowed) Descriptor ¶
func (CheckResponse_Allowed) Descriptor() protoreflect.EnumDescriptor
func (CheckResponse_Allowed) Enum ¶
func (x CheckResponse_Allowed) Enum() *CheckResponse_Allowed
func (CheckResponse_Allowed) EnumDescriptor
deprecated
func (CheckResponse_Allowed) EnumDescriptor() ([]byte, []int)
Deprecated: Use CheckResponse_Allowed.Descriptor instead.
func (CheckResponse_Allowed) Number ¶
func (x CheckResponse_Allowed) Number() protoreflect.EnumNumber
func (CheckResponse_Allowed) String ¶
func (x CheckResponse_Allowed) String() string
func (CheckResponse_Allowed) Type ¶
func (CheckResponse_Allowed) Type() protoreflect.EnumType
type Consistency ¶
type Consistency struct {
// Types that are valid to be assigned to Requirement:
//
// *Consistency_MinimizeLatency
// *Consistency_AtLeastAsFresh
Requirement isConsistency_Requirement `protobuf_oneof:"requirement"`
// contains filtered or unexported fields
}
Defines how a request is handled by the service.
func (*Consistency) Descriptor
deprecated
func (*Consistency) Descriptor() ([]byte, []int)
Deprecated: Use Consistency.ProtoReflect.Descriptor instead.
func (*Consistency) GetAtLeastAsFresh ¶
func (x *Consistency) GetAtLeastAsFresh() *ConsistencyToken
func (*Consistency) GetMinimizeLatency ¶
func (x *Consistency) GetMinimizeLatency() bool
func (*Consistency) GetRequirement ¶
func (x *Consistency) GetRequirement() isConsistency_Requirement
func (*Consistency) ProtoMessage ¶
func (*Consistency) ProtoMessage()
func (*Consistency) ProtoReflect ¶
func (x *Consistency) ProtoReflect() protoreflect.Message
func (*Consistency) Reset ¶
func (x *Consistency) Reset()
func (*Consistency) String ¶
func (x *Consistency) String() string
type ConsistencyToken ¶
type ConsistencyToken struct {
Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
// contains filtered or unexported fields
}
The ConsistencyToken is used to provide consistency between write and read requests.
func (*ConsistencyToken) Descriptor
deprecated
func (*ConsistencyToken) Descriptor() ([]byte, []int)
Deprecated: Use ConsistencyToken.ProtoReflect.Descriptor instead.
func (*ConsistencyToken) GetToken ¶
func (x *ConsistencyToken) GetToken() string
func (*ConsistencyToken) ProtoMessage ¶
func (*ConsistencyToken) ProtoMessage()
func (*ConsistencyToken) ProtoReflect ¶
func (x *ConsistencyToken) ProtoReflect() protoreflect.Message
func (*ConsistencyToken) Reset ¶
func (x *ConsistencyToken) Reset()
func (*ConsistencyToken) String ¶
func (x *ConsistencyToken) String() string
type Consistency_AtLeastAsFresh ¶
type Consistency_AtLeastAsFresh struct {
// All data used in the API call must be *at least as fresh*
// as found in the ConsistencyToken. More recent data might be used
// if available or faster.
AtLeastAsFresh *ConsistencyToken `protobuf:"bytes,2,opt,name=at_least_as_fresh,json=atLeastAsFresh,proto3,oneof"`
}
type Consistency_MinimizeLatency ¶
type Consistency_MinimizeLatency struct {
// The service selects the fastest snapshot available.
// *Must* be set true if used.
MinimizeLatency bool `protobuf:"varint,1,opt,name=minimize_latency,json=minimizeLatency,proto3,oneof"`
}
type CreateTuplesRequest ¶
type CreateTuplesRequest struct {
// Whether or not the request should ignore existing tuples (`true`),
// or if the request should fail if the same tuple already exists (`false`).
// Defaults to `false`.
Upsert bool `protobuf:"varint,1,opt,name=upsert,proto3" json:"upsert,omitempty"`
Tuples []*Relationship `protobuf:"bytes,2,rep,name=tuples,proto3" json:"tuples,omitempty"`
FencingCheck *FencingCheck `protobuf:"bytes,3,opt,name=fencing_check,json=fencingCheck,proto3,oneof" json:"fencing_check,omitempty"`
// contains filtered or unexported fields
}
func (*CreateTuplesRequest) Descriptor
deprecated
func (*CreateTuplesRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateTuplesRequest.ProtoReflect.Descriptor instead.
func (*CreateTuplesRequest) GetFencingCheck ¶
func (x *CreateTuplesRequest) GetFencingCheck() *FencingCheck
func (*CreateTuplesRequest) GetTuples ¶
func (x *CreateTuplesRequest) GetTuples() []*Relationship
func (*CreateTuplesRequest) GetUpsert ¶
func (x *CreateTuplesRequest) GetUpsert() bool
func (*CreateTuplesRequest) ProtoMessage ¶
func (*CreateTuplesRequest) ProtoMessage()
func (*CreateTuplesRequest) ProtoReflect ¶
func (x *CreateTuplesRequest) ProtoReflect() protoreflect.Message
func (*CreateTuplesRequest) Reset ¶
func (x *CreateTuplesRequest) Reset()
func (*CreateTuplesRequest) String ¶
func (x *CreateTuplesRequest) String() string
type CreateTuplesResponse ¶
type CreateTuplesResponse struct {
ConsistencyToken *ConsistencyToken `protobuf:"bytes,2,opt,name=consistency_token,json=consistencyToken,proto3" json:"consistency_token,omitempty"`
// contains filtered or unexported fields
}
func (*CreateTuplesResponse) Descriptor
deprecated
func (*CreateTuplesResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateTuplesResponse.ProtoReflect.Descriptor instead.
func (*CreateTuplesResponse) GetConsistencyToken ¶
func (x *CreateTuplesResponse) GetConsistencyToken() *ConsistencyToken
func (*CreateTuplesResponse) ProtoMessage ¶
func (*CreateTuplesResponse) ProtoMessage()
func (*CreateTuplesResponse) ProtoReflect ¶
func (x *CreateTuplesResponse) ProtoReflect() protoreflect.Message
func (*CreateTuplesResponse) Reset ¶
func (x *CreateTuplesResponse) Reset()
func (*CreateTuplesResponse) String ¶
func (x *CreateTuplesResponse) String() string
type DeleteTuplesRequest ¶
type DeleteTuplesRequest struct {
Filter *RelationTupleFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
FencingCheck *FencingCheck `protobuf:"bytes,2,opt,name=fencing_check,json=fencingCheck,proto3,oneof" json:"fencing_check,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteTuplesRequest) Descriptor
deprecated
func (*DeleteTuplesRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteTuplesRequest.ProtoReflect.Descriptor instead.
func (*DeleteTuplesRequest) GetFencingCheck ¶
func (x *DeleteTuplesRequest) GetFencingCheck() *FencingCheck
func (*DeleteTuplesRequest) GetFilter ¶
func (x *DeleteTuplesRequest) GetFilter() *RelationTupleFilter
func (*DeleteTuplesRequest) ProtoMessage ¶
func (*DeleteTuplesRequest) ProtoMessage()
func (*DeleteTuplesRequest) ProtoReflect ¶
func (x *DeleteTuplesRequest) ProtoReflect() protoreflect.Message
func (*DeleteTuplesRequest) Reset ¶
func (x *DeleteTuplesRequest) Reset()
func (*DeleteTuplesRequest) String ¶
func (x *DeleteTuplesRequest) String() string
type DeleteTuplesResponse ¶
type DeleteTuplesResponse struct {
ConsistencyToken *ConsistencyToken `protobuf:"bytes,2,opt,name=consistency_token,json=consistencyToken,proto3" json:"consistency_token,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteTuplesResponse) Descriptor
deprecated
func (*DeleteTuplesResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteTuplesResponse.ProtoReflect.Descriptor instead.
func (*DeleteTuplesResponse) GetConsistencyToken ¶
func (x *DeleteTuplesResponse) GetConsistencyToken() *ConsistencyToken
func (*DeleteTuplesResponse) ProtoMessage ¶
func (*DeleteTuplesResponse) ProtoMessage()
func (*DeleteTuplesResponse) ProtoReflect ¶
func (x *DeleteTuplesResponse) ProtoReflect() protoreflect.Message
func (*DeleteTuplesResponse) Reset ¶
func (x *DeleteTuplesResponse) Reset()
func (*DeleteTuplesResponse) String ¶
func (x *DeleteTuplesResponse) String() string
type FencingCheck ¶
type FencingCheck struct {
LockId string `protobuf:"bytes,1,opt,name=lock_id,json=lockId,proto3" json:"lock_id,omitempty"`
LockToken string `protobuf:"bytes,2,opt,name=lock_token,json=lockToken,proto3" json:"lock_token,omitempty"`
// contains filtered or unexported fields
}
func (*FencingCheck) Descriptor
deprecated
func (*FencingCheck) Descriptor() ([]byte, []int)
Deprecated: Use FencingCheck.ProtoReflect.Descriptor instead.
func (*FencingCheck) GetLockId ¶
func (x *FencingCheck) GetLockId() string
func (*FencingCheck) GetLockToken ¶
func (x *FencingCheck) GetLockToken() string
func (*FencingCheck) ProtoMessage ¶
func (*FencingCheck) ProtoMessage()
func (*FencingCheck) ProtoReflect ¶
func (x *FencingCheck) ProtoReflect() protoreflect.Message
func (*FencingCheck) Reset ¶
func (x *FencingCheck) Reset()
func (*FencingCheck) String ¶
func (x *FencingCheck) String() string
type ImportBulkTuplesRequest ¶
type ImportBulkTuplesRequest struct {
Tuples []*Relationship `protobuf:"bytes,1,rep,name=tuples,proto3" json:"tuples,omitempty"`
// contains filtered or unexported fields
}
func (*ImportBulkTuplesRequest) Descriptor
deprecated
func (*ImportBulkTuplesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ImportBulkTuplesRequest.ProtoReflect.Descriptor instead.
func (*ImportBulkTuplesRequest) GetTuples ¶
func (x *ImportBulkTuplesRequest) GetTuples() []*Relationship
func (*ImportBulkTuplesRequest) ProtoMessage ¶
func (*ImportBulkTuplesRequest) ProtoMessage()
func (*ImportBulkTuplesRequest) ProtoReflect ¶
func (x *ImportBulkTuplesRequest) ProtoReflect() protoreflect.Message
func (*ImportBulkTuplesRequest) Reset ¶
func (x *ImportBulkTuplesRequest) Reset()
func (*ImportBulkTuplesRequest) String ¶
func (x *ImportBulkTuplesRequest) String() string
type ImportBulkTuplesResponse ¶
type ImportBulkTuplesResponse struct {
NumImported uint64 `protobuf:"varint,1,opt,name=num_imported,json=numImported,proto3" json:"num_imported,omitempty"`
// contains filtered or unexported fields
}
func (*ImportBulkTuplesResponse) Descriptor
deprecated
func (*ImportBulkTuplesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ImportBulkTuplesResponse.ProtoReflect.Descriptor instead.
func (*ImportBulkTuplesResponse) GetNumImported ¶
func (x *ImportBulkTuplesResponse) GetNumImported() uint64
func (*ImportBulkTuplesResponse) ProtoMessage ¶
func (*ImportBulkTuplesResponse) ProtoMessage()
func (*ImportBulkTuplesResponse) ProtoReflect ¶
func (x *ImportBulkTuplesResponse) ProtoReflect() protoreflect.Message
func (*ImportBulkTuplesResponse) Reset ¶
func (x *ImportBulkTuplesResponse) Reset()
func (*ImportBulkTuplesResponse) String ¶
func (x *ImportBulkTuplesResponse) String() string
type KesselCheckServiceClient ¶
type KesselCheckServiceClient interface {
// Checks for the existence of a single Relationship
// (a Relation between a Resource and a Subject or Subject Set).
Check(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error)
CheckForUpdate(ctx context.Context, in *CheckForUpdateRequest, opts ...grpc.CallOption) (*CheckForUpdateResponse, error)
CheckBulk(ctx context.Context, in *CheckBulkRequest, opts ...grpc.CallOption) (*CheckBulkResponse, error)
}
KesselCheckServiceClient is the client API for KesselCheckService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewKesselCheckServiceClient ¶
func NewKesselCheckServiceClient(cc grpc.ClientConnInterface) KesselCheckServiceClient
type KesselCheckServiceHTTPClient ¶
type KesselCheckServiceHTTPClient interface {
// Check Checks for the existence of a single Relationship
// (a Relation between a Resource and a Subject or Subject Set).
Check(ctx context.Context, req *CheckRequest, opts ...http.CallOption) (rsp *CheckResponse, err error)
CheckBulk(ctx context.Context, req *CheckBulkRequest, opts ...http.CallOption) (rsp *CheckBulkResponse, err error)
CheckForUpdate(ctx context.Context, req *CheckForUpdateRequest, opts ...http.CallOption) (rsp *CheckForUpdateResponse, err error)
}
func NewKesselCheckServiceHTTPClient ¶
func NewKesselCheckServiceHTTPClient(client *http.Client) KesselCheckServiceHTTPClient
type KesselCheckServiceHTTPClientImpl ¶
type KesselCheckServiceHTTPClientImpl struct {
// contains filtered or unexported fields
}
func (*KesselCheckServiceHTTPClientImpl) Check ¶
func (c *KesselCheckServiceHTTPClientImpl) Check(ctx context.Context, in *CheckRequest, opts ...http.CallOption) (*CheckResponse, error)
Check Checks for the existence of a single Relationship (a Relation between a Resource and a Subject or Subject Set).
func (*KesselCheckServiceHTTPClientImpl) CheckBulk ¶
func (c *KesselCheckServiceHTTPClientImpl) CheckBulk(ctx context.Context, in *CheckBulkRequest, opts ...http.CallOption) (*CheckBulkResponse, error)
func (*KesselCheckServiceHTTPClientImpl) CheckForUpdate ¶
func (c *KesselCheckServiceHTTPClientImpl) CheckForUpdate(ctx context.Context, in *CheckForUpdateRequest, opts ...http.CallOption) (*CheckForUpdateResponse, error)
type KesselCheckServiceHTTPServer ¶
type KesselCheckServiceHTTPServer interface {
// Check Checks for the existence of a single Relationship
// (a Relation between a Resource and a Subject or Subject Set).
Check(context.Context, *CheckRequest) (*CheckResponse, error)
CheckBulk(context.Context, *CheckBulkRequest) (*CheckBulkResponse, error)
CheckForUpdate(context.Context, *CheckForUpdateRequest) (*CheckForUpdateResponse, error)
}
type KesselCheckServiceServer ¶
type KesselCheckServiceServer interface {
// Checks for the existence of a single Relationship
// (a Relation between a Resource and a Subject or Subject Set).
Check(context.Context, *CheckRequest) (*CheckResponse, error)
CheckForUpdate(context.Context, *CheckForUpdateRequest) (*CheckForUpdateResponse, error)
CheckBulk(context.Context, *CheckBulkRequest) (*CheckBulkResponse, error)
// contains filtered or unexported methods
}
KesselCheckServiceServer is the server API for KesselCheckService service. All implementations must embed UnimplementedKesselCheckServiceServer for forward compatibility.
type KesselLookupServiceClient ¶
type KesselLookupServiceClient interface {
LookupSubjects(ctx context.Context, in *LookupSubjectsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LookupSubjectsResponse], error)
LookupResources(ctx context.Context, in *LookupResourcesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LookupResourcesResponse], error)
}
KesselLookupServiceClient is the client API for KesselLookupService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewKesselLookupServiceClient ¶
func NewKesselLookupServiceClient(cc grpc.ClientConnInterface) KesselLookupServiceClient
type KesselLookupServiceServer ¶
type KesselLookupServiceServer interface {
LookupSubjects(*LookupSubjectsRequest, grpc.ServerStreamingServer[LookupSubjectsResponse]) error
LookupResources(*LookupResourcesRequest, grpc.ServerStreamingServer[LookupResourcesResponse]) error
// contains filtered or unexported methods
}
KesselLookupServiceServer is the server API for KesselLookupService service. All implementations must embed UnimplementedKesselLookupServiceServer for forward compatibility.
type KesselLookupService_LookupResourcesClient ¶
type KesselLookupService_LookupResourcesClient = grpc.ServerStreamingClient[LookupResourcesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KesselLookupService_LookupResourcesServer ¶
type KesselLookupService_LookupResourcesServer = grpc.ServerStreamingServer[LookupResourcesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KesselLookupService_LookupSubjectsClient ¶
type KesselLookupService_LookupSubjectsClient = grpc.ServerStreamingClient[LookupSubjectsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KesselLookupService_LookupSubjectsServer ¶
type KesselLookupService_LookupSubjectsServer = grpc.ServerStreamingServer[LookupSubjectsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KesselTupleServiceClient ¶
type KesselTupleServiceClient interface {
CreateTuples(ctx context.Context, in *CreateTuplesRequest, opts ...grpc.CallOption) (*CreateTuplesResponse, error)
ReadTuples(ctx context.Context, in *ReadTuplesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ReadTuplesResponse], error)
DeleteTuples(ctx context.Context, in *DeleteTuplesRequest, opts ...grpc.CallOption) (*DeleteTuplesResponse, error)
ImportBulkTuples(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[ImportBulkTuplesRequest, ImportBulkTuplesResponse], error)
AcquireLock(ctx context.Context, in *AcquireLockRequest, opts ...grpc.CallOption) (*AcquireLockResponse, error)
}
KesselTupleServiceClient is the client API for KesselTupleService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
KesselTupleServices manages the persisted _Tuples_ stored in the system..
A Tuple is an explicitly stated, persistent relation between a Resource and a Subject or Subject Set. It has the same _shape_ as a Relationship but is not the same thing as a Relationship.
A single Tuple may result in zero-to-many Relationships.
func NewKesselTupleServiceClient ¶
func NewKesselTupleServiceClient(cc grpc.ClientConnInterface) KesselTupleServiceClient
type KesselTupleServiceHTTPClient ¶
type KesselTupleServiceHTTPClient interface {
AcquireLock(ctx context.Context, req *AcquireLockRequest, opts ...http.CallOption) (rsp *AcquireLockResponse, err error)
CreateTuples(ctx context.Context, req *CreateTuplesRequest, opts ...http.CallOption) (rsp *CreateTuplesResponse, err error)
DeleteTuples(ctx context.Context, req *DeleteTuplesRequest, opts ...http.CallOption) (rsp *DeleteTuplesResponse, err error)
}
func NewKesselTupleServiceHTTPClient ¶
func NewKesselTupleServiceHTTPClient(client *http.Client) KesselTupleServiceHTTPClient
type KesselTupleServiceHTTPClientImpl ¶
type KesselTupleServiceHTTPClientImpl struct {
// contains filtered or unexported fields
}
func (*KesselTupleServiceHTTPClientImpl) AcquireLock ¶
func (c *KesselTupleServiceHTTPClientImpl) AcquireLock(ctx context.Context, in *AcquireLockRequest, opts ...http.CallOption) (*AcquireLockResponse, error)
func (*KesselTupleServiceHTTPClientImpl) CreateTuples ¶
func (c *KesselTupleServiceHTTPClientImpl) CreateTuples(ctx context.Context, in *CreateTuplesRequest, opts ...http.CallOption) (*CreateTuplesResponse, error)
func (*KesselTupleServiceHTTPClientImpl) DeleteTuples ¶
func (c *KesselTupleServiceHTTPClientImpl) DeleteTuples(ctx context.Context, in *DeleteTuplesRequest, opts ...http.CallOption) (*DeleteTuplesResponse, error)
type KesselTupleServiceHTTPServer ¶
type KesselTupleServiceHTTPServer interface {
AcquireLock(context.Context, *AcquireLockRequest) (*AcquireLockResponse, error)
CreateTuples(context.Context, *CreateTuplesRequest) (*CreateTuplesResponse, error)
DeleteTuples(context.Context, *DeleteTuplesRequest) (*DeleteTuplesResponse, error)
}
type KesselTupleServiceServer ¶
type KesselTupleServiceServer interface {
CreateTuples(context.Context, *CreateTuplesRequest) (*CreateTuplesResponse, error)
ReadTuples(*ReadTuplesRequest, grpc.ServerStreamingServer[ReadTuplesResponse]) error
DeleteTuples(context.Context, *DeleteTuplesRequest) (*DeleteTuplesResponse, error)
ImportBulkTuples(grpc.ClientStreamingServer[ImportBulkTuplesRequest, ImportBulkTuplesResponse]) error
AcquireLock(context.Context, *AcquireLockRequest) (*AcquireLockResponse, error)
// contains filtered or unexported methods
}
KesselTupleServiceServer is the server API for KesselTupleService service. All implementations must embed UnimplementedKesselTupleServiceServer for forward compatibility.
KesselTupleServices manages the persisted _Tuples_ stored in the system..
A Tuple is an explicitly stated, persistent relation between a Resource and a Subject or Subject Set. It has the same _shape_ as a Relationship but is not the same thing as a Relationship.
A single Tuple may result in zero-to-many Relationships.
type KesselTupleService_ImportBulkTuplesClient ¶
type KesselTupleService_ImportBulkTuplesClient = grpc.ClientStreamingClient[ImportBulkTuplesRequest, ImportBulkTuplesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KesselTupleService_ImportBulkTuplesServer ¶
type KesselTupleService_ImportBulkTuplesServer = grpc.ClientStreamingServer[ImportBulkTuplesRequest, ImportBulkTuplesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KesselTupleService_ReadTuplesClient ¶
type KesselTupleService_ReadTuplesClient = grpc.ServerStreamingClient[ReadTuplesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type KesselTupleService_ReadTuplesServer ¶
type KesselTupleService_ReadTuplesServer = grpc.ServerStreamingServer[ReadTuplesResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type LookupResourcesRequest ¶
type LookupResourcesRequest struct {
ResourceType *ObjectType `protobuf:"bytes,1,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
Relation string `protobuf:"bytes,2,opt,name=relation,proto3" json:"relation,omitempty"`
Subject *SubjectReference `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"`
Pagination *RequestPagination `protobuf:"bytes,4,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
Consistency *Consistency `protobuf:"bytes,5,opt,name=consistency,proto3,oneof" json:"consistency,omitempty"`
// contains filtered or unexported fields
}
func (*LookupResourcesRequest) Descriptor
deprecated
func (*LookupResourcesRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookupResourcesRequest.ProtoReflect.Descriptor instead.
func (*LookupResourcesRequest) GetConsistency ¶
func (x *LookupResourcesRequest) GetConsistency() *Consistency
func (*LookupResourcesRequest) GetPagination ¶
func (x *LookupResourcesRequest) GetPagination() *RequestPagination
func (*LookupResourcesRequest) GetRelation ¶
func (x *LookupResourcesRequest) GetRelation() string
func (*LookupResourcesRequest) GetResourceType ¶
func (x *LookupResourcesRequest) GetResourceType() *ObjectType
func (*LookupResourcesRequest) GetSubject ¶
func (x *LookupResourcesRequest) GetSubject() *SubjectReference
func (*LookupResourcesRequest) ProtoMessage ¶
func (*LookupResourcesRequest) ProtoMessage()
func (*LookupResourcesRequest) ProtoReflect ¶
func (x *LookupResourcesRequest) ProtoReflect() protoreflect.Message
func (*LookupResourcesRequest) Reset ¶
func (x *LookupResourcesRequest) Reset()
func (*LookupResourcesRequest) String ¶
func (x *LookupResourcesRequest) String() string
type LookupResourcesResponse ¶
type LookupResourcesResponse struct {
Resource *ObjectReference `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
Pagination *ResponsePagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
ConsistencyToken *ConsistencyToken `protobuf:"bytes,3,opt,name=consistency_token,json=consistencyToken,proto3" json:"consistency_token,omitempty"`
// contains filtered or unexported fields
}
func (*LookupResourcesResponse) Descriptor
deprecated
func (*LookupResourcesResponse) Descriptor() ([]byte, []int)
Deprecated: Use LookupResourcesResponse.ProtoReflect.Descriptor instead.
func (*LookupResourcesResponse) GetConsistencyToken ¶
func (x *LookupResourcesResponse) GetConsistencyToken() *ConsistencyToken
func (*LookupResourcesResponse) GetPagination ¶
func (x *LookupResourcesResponse) GetPagination() *ResponsePagination
func (*LookupResourcesResponse) GetResource ¶
func (x *LookupResourcesResponse) GetResource() *ObjectReference
func (*LookupResourcesResponse) ProtoMessage ¶
func (*LookupResourcesResponse) ProtoMessage()
func (*LookupResourcesResponse) ProtoReflect ¶
func (x *LookupResourcesResponse) ProtoReflect() protoreflect.Message
func (*LookupResourcesResponse) Reset ¶
func (x *LookupResourcesResponse) Reset()
func (*LookupResourcesResponse) String ¶
func (x *LookupResourcesResponse) String() string
type LookupSubjectsRequest ¶
type LookupSubjectsRequest struct {
Resource *ObjectReference `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
Relation string `protobuf:"bytes,2,opt,name=relation,proto3" json:"relation,omitempty"`
SubjectType *ObjectType `protobuf:"bytes,3,opt,name=subject_type,json=subjectType,proto3" json:"subject_type,omitempty"`
SubjectRelation *string `protobuf:"bytes,4,opt,name=subject_relation,json=subjectRelation,proto3,oneof" json:"subject_relation,omitempty"`
Pagination *RequestPagination `protobuf:"bytes,5,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
Consistency *Consistency `protobuf:"bytes,6,opt,name=consistency,proto3,oneof" json:"consistency,omitempty"`
// contains filtered or unexported fields
}
func (*LookupSubjectsRequest) Descriptor
deprecated
func (*LookupSubjectsRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookupSubjectsRequest.ProtoReflect.Descriptor instead.
func (*LookupSubjectsRequest) GetConsistency ¶
func (x *LookupSubjectsRequest) GetConsistency() *Consistency
func (*LookupSubjectsRequest) GetPagination ¶
func (x *LookupSubjectsRequest) GetPagination() *RequestPagination
func (*LookupSubjectsRequest) GetRelation ¶
func (x *LookupSubjectsRequest) GetRelation() string
func (*LookupSubjectsRequest) GetResource ¶
func (x *LookupSubjectsRequest) GetResource() *ObjectReference
func (*LookupSubjectsRequest) GetSubjectRelation ¶
func (x *LookupSubjectsRequest) GetSubjectRelation() string
func (*LookupSubjectsRequest) GetSubjectType ¶
func (x *LookupSubjectsRequest) GetSubjectType() *ObjectType
func (*LookupSubjectsRequest) ProtoMessage ¶
func (*LookupSubjectsRequest) ProtoMessage()
func (*LookupSubjectsRequest) ProtoReflect ¶
func (x *LookupSubjectsRequest) ProtoReflect() protoreflect.Message
func (*LookupSubjectsRequest) Reset ¶
func (x *LookupSubjectsRequest) Reset()
func (*LookupSubjectsRequest) String ¶
func (x *LookupSubjectsRequest) String() string
type LookupSubjectsResponse ¶
type LookupSubjectsResponse struct {
Subject *SubjectReference `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
Pagination *ResponsePagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
ConsistencyToken *ConsistencyToken `protobuf:"bytes,3,opt,name=consistency_token,json=consistencyToken,proto3" json:"consistency_token,omitempty"`
// contains filtered or unexported fields
}
func (*LookupSubjectsResponse) Descriptor
deprecated
func (*LookupSubjectsResponse) Descriptor() ([]byte, []int)
Deprecated: Use LookupSubjectsResponse.ProtoReflect.Descriptor instead.
func (*LookupSubjectsResponse) GetConsistencyToken ¶
func (x *LookupSubjectsResponse) GetConsistencyToken() *ConsistencyToken
func (*LookupSubjectsResponse) GetPagination ¶
func (x *LookupSubjectsResponse) GetPagination() *ResponsePagination
func (*LookupSubjectsResponse) GetSubject ¶
func (x *LookupSubjectsResponse) GetSubject() *SubjectReference
func (*LookupSubjectsResponse) ProtoMessage ¶
func (*LookupSubjectsResponse) ProtoMessage()
func (*LookupSubjectsResponse) ProtoReflect ¶
func (x *LookupSubjectsResponse) ProtoReflect() protoreflect.Message
func (*LookupSubjectsResponse) Reset ¶
func (x *LookupSubjectsResponse) Reset()
func (*LookupSubjectsResponse) String ¶
func (x *LookupSubjectsResponse) String() string
type ObjectReference ¶
type ObjectReference struct {
Type *ObjectType `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*ObjectReference) Descriptor
deprecated
func (*ObjectReference) Descriptor() ([]byte, []int)
Deprecated: Use ObjectReference.ProtoReflect.Descriptor instead.
func (*ObjectReference) GetId ¶
func (x *ObjectReference) GetId() string
func (*ObjectReference) GetType ¶
func (x *ObjectReference) GetType() *ObjectType
func (*ObjectReference) ProtoMessage ¶
func (*ObjectReference) ProtoMessage()
func (*ObjectReference) ProtoReflect ¶
func (x *ObjectReference) ProtoReflect() protoreflect.Message
func (*ObjectReference) Reset ¶
func (x *ObjectReference) Reset()
func (*ObjectReference) String ¶
func (x *ObjectReference) String() string
type ObjectType ¶
type ObjectType struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*ObjectType) Descriptor
deprecated
func (*ObjectType) Descriptor() ([]byte, []int)
Deprecated: Use ObjectType.ProtoReflect.Descriptor instead.
func (*ObjectType) GetName ¶
func (x *ObjectType) GetName() string
func (*ObjectType) GetNamespace ¶
func (x *ObjectType) GetNamespace() string
func (*ObjectType) ProtoMessage ¶
func (*ObjectType) ProtoMessage()
func (*ObjectType) ProtoReflect ¶
func (x *ObjectType) ProtoReflect() protoreflect.Message
func (*ObjectType) Reset ¶
func (x *ObjectType) Reset()
func (*ObjectType) String ¶
func (x *ObjectType) String() string
type ReadTuplesRequest ¶
type ReadTuplesRequest struct {
Filter *RelationTupleFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
Pagination *RequestPagination `protobuf:"bytes,2,opt,name=pagination,proto3,oneof" json:"pagination,omitempty"`
Consistency *Consistency `protobuf:"bytes,3,opt,name=consistency,proto3,oneof" json:"consistency,omitempty"`
// contains filtered or unexported fields
}
func (*ReadTuplesRequest) Descriptor
deprecated
func (*ReadTuplesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadTuplesRequest.ProtoReflect.Descriptor instead.
func (*ReadTuplesRequest) GetConsistency ¶
func (x *ReadTuplesRequest) GetConsistency() *Consistency
func (*ReadTuplesRequest) GetFilter ¶
func (x *ReadTuplesRequest) GetFilter() *RelationTupleFilter
func (*ReadTuplesRequest) GetPagination ¶
func (x *ReadTuplesRequest) GetPagination() *RequestPagination
func (*ReadTuplesRequest) ProtoMessage ¶
func (*ReadTuplesRequest) ProtoMessage()
func (*ReadTuplesRequest) ProtoReflect ¶
func (x *ReadTuplesRequest) ProtoReflect() protoreflect.Message
func (*ReadTuplesRequest) Reset ¶
func (x *ReadTuplesRequest) Reset()
func (*ReadTuplesRequest) String ¶
func (x *ReadTuplesRequest) String() string
type ReadTuplesResponse ¶
type ReadTuplesResponse struct {
Tuple *Relationship `protobuf:"bytes,1,opt,name=tuple,proto3" json:"tuple,omitempty"`
Pagination *ResponsePagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
ConsistencyToken *ConsistencyToken `protobuf:"bytes,3,opt,name=consistency_token,json=consistencyToken,proto3" json:"consistency_token,omitempty"`
// contains filtered or unexported fields
}
func (*ReadTuplesResponse) Descriptor
deprecated
func (*ReadTuplesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadTuplesResponse.ProtoReflect.Descriptor instead.
func (*ReadTuplesResponse) GetConsistencyToken ¶
func (x *ReadTuplesResponse) GetConsistencyToken() *ConsistencyToken
func (*ReadTuplesResponse) GetPagination ¶
func (x *ReadTuplesResponse) GetPagination() *ResponsePagination
func (*ReadTuplesResponse) GetTuple ¶
func (x *ReadTuplesResponse) GetTuple() *Relationship
func (*ReadTuplesResponse) ProtoMessage ¶
func (*ReadTuplesResponse) ProtoMessage()
func (*ReadTuplesResponse) ProtoReflect ¶
func (x *ReadTuplesResponse) ProtoReflect() protoreflect.Message
func (*ReadTuplesResponse) Reset ¶
func (x *ReadTuplesResponse) Reset()
func (*ReadTuplesResponse) String ¶
func (x *ReadTuplesResponse) String() string
type RelationTupleFilter ¶
type RelationTupleFilter struct {
ResourceNamespace *string `protobuf:"bytes,1,opt,name=resource_namespace,json=resourceNamespace,proto3,oneof" json:"resource_namespace,omitempty"`
ResourceType *string `protobuf:"bytes,2,opt,name=resource_type,json=resourceType,proto3,oneof" json:"resource_type,omitempty"`
ResourceId *string `protobuf:"bytes,3,opt,name=resource_id,json=resourceId,proto3,oneof" json:"resource_id,omitempty"`
Relation *string `protobuf:"bytes,4,opt,name=relation,proto3,oneof" json:"relation,omitempty"`
SubjectFilter *SubjectFilter `protobuf:"bytes,5,opt,name=subject_filter,json=subjectFilter,proto3,oneof" json:"subject_filter,omitempty"`
// contains filtered or unexported fields
}
RelationTupleFilter is used to filter tuples based on their resource, relation, and subject. All fields are optional but capabilities may vary based on the chosen store and its indexes. At least one field must be provided.
func (*RelationTupleFilter) Descriptor
deprecated
func (*RelationTupleFilter) Descriptor() ([]byte, []int)
Deprecated: Use RelationTupleFilter.ProtoReflect.Descriptor instead.
func (*RelationTupleFilter) GetRelation ¶
func (x *RelationTupleFilter) GetRelation() string
func (*RelationTupleFilter) GetResourceId ¶
func (x *RelationTupleFilter) GetResourceId() string
func (*RelationTupleFilter) GetResourceNamespace ¶
func (x *RelationTupleFilter) GetResourceNamespace() string
func (*RelationTupleFilter) GetResourceType ¶
func (x *RelationTupleFilter) GetResourceType() string
func (*RelationTupleFilter) GetSubjectFilter ¶
func (x *RelationTupleFilter) GetSubjectFilter() *SubjectFilter
func (*RelationTupleFilter) ProtoMessage ¶
func (*RelationTupleFilter) ProtoMessage()
func (*RelationTupleFilter) ProtoReflect ¶
func (x *RelationTupleFilter) ProtoReflect() protoreflect.Message
func (*RelationTupleFilter) Reset ¶
func (x *RelationTupleFilter) Reset()
func (*RelationTupleFilter) String ¶
func (x *RelationTupleFilter) String() string
type Relationship ¶
type Relationship struct {
Resource *ObjectReference `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
Relation string `protobuf:"bytes,2,opt,name=relation,proto3" json:"relation,omitempty"`
Subject *SubjectReference `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"`
// contains filtered or unexported fields
}
A _Relationship_ is the realization of a _Relation_ (a string) between a _Resource_ and a _Subject_ or a _Subject Set_ (known as a Userset in Zanzibar).
All Relationships are object-object relations. "Resource" and "Subject" are relative terms which define the direction of a Relation. That is, Relations are unidirectional. If you reverse the Subject and Resource, it is a different Relation and a different Relationship. Conventionally, we generally refer to the Resource first, then Subject, following the direction of typical graph traversal (Resource to Subject).
func (*Relationship) Descriptor
deprecated
func (*Relationship) Descriptor() ([]byte, []int)
Deprecated: Use Relationship.ProtoReflect.Descriptor instead.
func (*Relationship) GetRelation ¶
func (x *Relationship) GetRelation() string
func (*Relationship) GetResource ¶
func (x *Relationship) GetResource() *ObjectReference
func (*Relationship) GetSubject ¶
func (x *Relationship) GetSubject() *SubjectReference
func (*Relationship) ProtoMessage ¶
func (*Relationship) ProtoMessage()
func (*Relationship) ProtoReflect ¶
func (x *Relationship) ProtoReflect() protoreflect.Message
func (*Relationship) Reset ¶
func (x *Relationship) Reset()
func (*Relationship) String ¶
func (x *Relationship) String() string
type RequestPagination ¶
type RequestPagination struct {
Limit uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
ContinuationToken *string `protobuf:"bytes,2,opt,name=continuation_token,json=continuationToken,proto3,oneof" json:"continuation_token,omitempty"`
// contains filtered or unexported fields
}
func (*RequestPagination) Descriptor
deprecated
func (*RequestPagination) Descriptor() ([]byte, []int)
Deprecated: Use RequestPagination.ProtoReflect.Descriptor instead.
func (*RequestPagination) GetContinuationToken ¶
func (x *RequestPagination) GetContinuationToken() string
func (*RequestPagination) GetLimit ¶
func (x *RequestPagination) GetLimit() uint32
func (*RequestPagination) ProtoMessage ¶
func (*RequestPagination) ProtoMessage()
func (*RequestPagination) ProtoReflect ¶
func (x *RequestPagination) ProtoReflect() protoreflect.Message
func (*RequestPagination) Reset ¶
func (x *RequestPagination) Reset()
func (*RequestPagination) String ¶
func (x *RequestPagination) String() string
type ResponsePagination ¶
type ResponsePagination struct {
ContinuationToken string `protobuf:"bytes,1,opt,name=continuation_token,json=continuationToken,proto3" json:"continuation_token,omitempty"`
// contains filtered or unexported fields
}
func (*ResponsePagination) Descriptor
deprecated
func (*ResponsePagination) Descriptor() ([]byte, []int)
Deprecated: Use ResponsePagination.ProtoReflect.Descriptor instead.
func (*ResponsePagination) GetContinuationToken ¶
func (x *ResponsePagination) GetContinuationToken() string
func (*ResponsePagination) ProtoMessage ¶
func (*ResponsePagination) ProtoMessage()
func (*ResponsePagination) ProtoReflect ¶
func (x *ResponsePagination) ProtoReflect() protoreflect.Message
func (*ResponsePagination) Reset ¶
func (x *ResponsePagination) Reset()
func (*ResponsePagination) String ¶
func (x *ResponsePagination) String() string
type SubjectFilter ¶
type SubjectFilter struct {
SubjectNamespace *string `protobuf:"bytes,1,opt,name=subject_namespace,json=subjectNamespace,proto3,oneof" json:"subject_namespace,omitempty"`
SubjectType *string `protobuf:"bytes,2,opt,name=subject_type,json=subjectType,proto3,oneof" json:"subject_type,omitempty"`
SubjectId *string `protobuf:"bytes,3,opt,name=subject_id,json=subjectId,proto3,oneof" json:"subject_id,omitempty"`
Relation *string `protobuf:"bytes,4,opt,name=relation,proto3,oneof" json:"relation,omitempty"`
// contains filtered or unexported fields
}
func (*SubjectFilter) Descriptor
deprecated
func (*SubjectFilter) Descriptor() ([]byte, []int)
Deprecated: Use SubjectFilter.ProtoReflect.Descriptor instead.
func (*SubjectFilter) GetRelation ¶
func (x *SubjectFilter) GetRelation() string
func (*SubjectFilter) GetSubjectId ¶
func (x *SubjectFilter) GetSubjectId() string
func (*SubjectFilter) GetSubjectNamespace ¶
func (x *SubjectFilter) GetSubjectNamespace() string
func (*SubjectFilter) GetSubjectType ¶
func (x *SubjectFilter) GetSubjectType() string
func (*SubjectFilter) ProtoMessage ¶
func (*SubjectFilter) ProtoMessage()
func (*SubjectFilter) ProtoReflect ¶
func (x *SubjectFilter) ProtoReflect() protoreflect.Message
func (*SubjectFilter) Reset ¶
func (x *SubjectFilter) Reset()
func (*SubjectFilter) String ¶
func (x *SubjectFilter) String() string
type SubjectReference ¶
type SubjectReference struct {
// An optional relation which points to a set of Subjects instead of the single Subject.
// e.g. "members" or "owners" of a group identified in `subject`.
Relation *string `protobuf:"bytes,1,opt,name=relation,proto3,oneof" json:"relation,omitempty"`
Subject *ObjectReference `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
// contains filtered or unexported fields
}
A reference to a Subject or, if a `relation` is provided, a Subject Set.
func (*SubjectReference) Descriptor
deprecated
func (*SubjectReference) Descriptor() ([]byte, []int)
Deprecated: Use SubjectReference.ProtoReflect.Descriptor instead.
func (*SubjectReference) GetRelation ¶
func (x *SubjectReference) GetRelation() string
func (*SubjectReference) GetSubject ¶
func (x *SubjectReference) GetSubject() *ObjectReference
func (*SubjectReference) ProtoMessage ¶
func (*SubjectReference) ProtoMessage()
func (*SubjectReference) ProtoReflect ¶
func (x *SubjectReference) ProtoReflect() protoreflect.Message
func (*SubjectReference) Reset ¶
func (x *SubjectReference) Reset()
func (*SubjectReference) String ¶
func (x *SubjectReference) String() string
type UnimplementedKesselCheckServiceServer ¶
type UnimplementedKesselCheckServiceServer struct{}
UnimplementedKesselCheckServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedKesselCheckServiceServer) Check ¶
func (UnimplementedKesselCheckServiceServer) Check(context.Context, *CheckRequest) (*CheckResponse, error)
func (UnimplementedKesselCheckServiceServer) CheckBulk ¶
func (UnimplementedKesselCheckServiceServer) CheckBulk(context.Context, *CheckBulkRequest) (*CheckBulkResponse, error)
func (UnimplementedKesselCheckServiceServer) CheckForUpdate ¶
func (UnimplementedKesselCheckServiceServer) CheckForUpdate(context.Context, *CheckForUpdateRequest) (*CheckForUpdateResponse, error)
type UnimplementedKesselLookupServiceServer ¶
type UnimplementedKesselLookupServiceServer struct{}
UnimplementedKesselLookupServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedKesselLookupServiceServer) LookupResources ¶
func (UnimplementedKesselLookupServiceServer) LookupResources(*LookupResourcesRequest, grpc.ServerStreamingServer[LookupResourcesResponse]) error
func (UnimplementedKesselLookupServiceServer) LookupSubjects ¶
func (UnimplementedKesselLookupServiceServer) LookupSubjects(*LookupSubjectsRequest, grpc.ServerStreamingServer[LookupSubjectsResponse]) error
type UnimplementedKesselTupleServiceServer ¶
type UnimplementedKesselTupleServiceServer struct{}
UnimplementedKesselTupleServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedKesselTupleServiceServer) AcquireLock ¶
func (UnimplementedKesselTupleServiceServer) AcquireLock(context.Context, *AcquireLockRequest) (*AcquireLockResponse, error)
func (UnimplementedKesselTupleServiceServer) CreateTuples ¶
func (UnimplementedKesselTupleServiceServer) CreateTuples(context.Context, *CreateTuplesRequest) (*CreateTuplesResponse, error)
func (UnimplementedKesselTupleServiceServer) DeleteTuples ¶
func (UnimplementedKesselTupleServiceServer) DeleteTuples(context.Context, *DeleteTuplesRequest) (*DeleteTuplesResponse, error)
func (UnimplementedKesselTupleServiceServer) ImportBulkTuples ¶
func (UnimplementedKesselTupleServiceServer) ImportBulkTuples(grpc.ClientStreamingServer[ImportBulkTuplesRequest, ImportBulkTuplesResponse]) error
func (UnimplementedKesselTupleServiceServer) ReadTuples ¶
func (UnimplementedKesselTupleServiceServer) ReadTuples(*ReadTuplesRequest, grpc.ServerStreamingServer[ReadTuplesResponse]) error
type UnsafeKesselCheckServiceServer ¶
type UnsafeKesselCheckServiceServer interface {
// contains filtered or unexported methods
}
UnsafeKesselCheckServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KesselCheckServiceServer will result in compilation errors.
type UnsafeKesselLookupServiceServer ¶
type UnsafeKesselLookupServiceServer interface {
// contains filtered or unexported methods
}
UnsafeKesselLookupServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KesselLookupServiceServer will result in compilation errors.
type UnsafeKesselTupleServiceServer ¶
type UnsafeKesselTupleServiceServer interface {
// contains filtered or unexported methods
}
UnsafeKesselTupleServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KesselTupleServiceServer will result in compilation errors.