Documentation
¶
Index ¶
- Variables
- func RegisterUpdateServer(s grpc.ServiceRegistrar, srv UpdateServer)
- type DeleteFilter
- func (*DeleteFilter) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteFilter) GetKinds() []relationships.Kind
- func (x *DeleteFilter) GetObjects() []*relationships.Object
- func (x *DeleteFilter) GetRoles() []*relationships.Role
- func (x *DeleteFilter) GetSubjects() []*relationships.Subject
- func (*DeleteFilter) ProtoMessage()
- func (x *DeleteFilter) ProtoReflect() protoreflect.Message
- func (x *DeleteFilter) Reset()
- func (x *DeleteFilter) String() string
- type DeleteRelationshipsByFilterRequest
- func (*DeleteRelationshipsByFilterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRelationshipsByFilterRequest) GetFilter() *DeleteFilter
- func (*DeleteRelationshipsByFilterRequest) ProtoMessage()
- func (x *DeleteRelationshipsByFilterRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRelationshipsByFilterRequest) Reset()
- func (x *DeleteRelationshipsByFilterRequest) String() string
- type DeleteRelationshipsByFilterResponse
- func (*DeleteRelationshipsByFilterResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRelationshipsByFilterResponse) GetDeletedCount() int64
- func (*DeleteRelationshipsByFilterResponse) ProtoMessage()
- func (x *DeleteRelationshipsByFilterResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteRelationshipsByFilterResponse) Reset()
- func (x *DeleteRelationshipsByFilterResponse) String() string
- type DeleteRelationshipsRequest
- func (*DeleteRelationshipsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRelationshipsRequest) GetKeys() []*relationships.RelationshipKey
- func (*DeleteRelationshipsRequest) ProtoMessage()
- func (x *DeleteRelationshipsRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRelationshipsRequest) Reset()
- func (x *DeleteRelationshipsRequest) String() string
- type DeleteRelationshipsResponse
- type HealthRequest
- type HealthResponse
- type UnimplementedUpdateServer
- func (UnimplementedUpdateServer) DeleteRelationships(context.Context, *DeleteRelationshipsRequest) (*DeleteRelationshipsResponse, error)
- func (UnimplementedUpdateServer) DeleteRelationshipsByFilter(context.Context, *DeleteRelationshipsByFilterRequest) (*DeleteRelationshipsByFilterResponse, error)
- func (UnimplementedUpdateServer) Health(context.Context, *HealthRequest) (*HealthResponse, error)
- func (UnimplementedUpdateServer) WriteRelationships(context.Context, *WriteRelationshipsRequest) (*WriteRelationshipsResponse, error)
- type UnsafeUpdateServer
- type UpdateClient
- type UpdateServer
- type WriteRelationshipsRequest
- func (*WriteRelationshipsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WriteRelationshipsRequest) GetRelationships() []*relationships.RelationshipInput
- func (*WriteRelationshipsRequest) ProtoMessage()
- func (x *WriteRelationshipsRequest) ProtoReflect() protoreflect.Message
- func (x *WriteRelationshipsRequest) Reset()
- func (x *WriteRelationshipsRequest) String() string
- type WriteRelationshipsResponse
- func (*WriteRelationshipsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WriteRelationshipsResponse) GetRelationships() []*relationships.Relationship
- func (*WriteRelationshipsResponse) ProtoMessage()
- func (x *WriteRelationshipsResponse) ProtoReflect() protoreflect.Message
- func (x *WriteRelationshipsResponse) Reset()
- func (x *WriteRelationshipsResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var File_proto_update_update_proto protoreflect.FileDescriptor
var Update_ServiceDesc = grpc.ServiceDesc{ ServiceName: "update.Update", HandlerType: (*UpdateServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Health", Handler: _Update_Health_Handler, }, { MethodName: "WriteRelationships", Handler: _Update_WriteRelationships_Handler, }, { MethodName: "DeleteRelationships", Handler: _Update_DeleteRelationships_Handler, }, { MethodName: "DeleteRelationshipsByFilter", Handler: _Update_DeleteRelationshipsByFilter_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/update/update.proto", }
Update_ServiceDesc is the grpc.ServiceDesc for Update service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterUpdateServer ¶
func RegisterUpdateServer(s grpc.ServiceRegistrar, srv UpdateServer)
Types ¶
type DeleteFilter ¶
type DeleteFilter struct {
Subjects []*relationships.Subject `protobuf:"bytes,1,rep,name=subjects,proto3" json:"subjects,omitempty"` // each must satisfy Subject validation
Objects []*relationships.Object `protobuf:"bytes,2,rep,name=objects,proto3" json:"objects,omitempty"`
Kinds []relationships.Kind `protobuf:"varint,3,rep,packed,name=kinds,proto3,enum=relationships.Kind" json:"kinds,omitempty"` // entries must not be _UNSPECIFIED
Roles []*relationships.Role `protobuf:"bytes,4,rep,name=roles,proto3" json:"roles,omitempty"`
// contains filtered or unexported fields
}
At least one of `subjects` or `objects` must be non-empty; an unscoped filter is rejected.
func (*DeleteFilter) Descriptor
deprecated
func (*DeleteFilter) Descriptor() ([]byte, []int)
Deprecated: Use DeleteFilter.ProtoReflect.Descriptor instead.
func (*DeleteFilter) GetKinds ¶
func (x *DeleteFilter) GetKinds() []relationships.Kind
func (*DeleteFilter) GetObjects ¶
func (x *DeleteFilter) GetObjects() []*relationships.Object
func (*DeleteFilter) GetRoles ¶
func (x *DeleteFilter) GetRoles() []*relationships.Role
func (*DeleteFilter) GetSubjects ¶
func (x *DeleteFilter) GetSubjects() []*relationships.Subject
func (*DeleteFilter) ProtoMessage ¶
func (*DeleteFilter) ProtoMessage()
func (*DeleteFilter) ProtoReflect ¶
func (x *DeleteFilter) ProtoReflect() protoreflect.Message
func (*DeleteFilter) Reset ¶
func (x *DeleteFilter) Reset()
func (*DeleteFilter) String ¶
func (x *DeleteFilter) String() string
type DeleteRelationshipsByFilterRequest ¶
type DeleteRelationshipsByFilterRequest struct {
Filter *DeleteFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` // required; at least one of `subjects` or `objects` non-empty
// contains filtered or unexported fields
}
func (*DeleteRelationshipsByFilterRequest) Descriptor
deprecated
func (*DeleteRelationshipsByFilterRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRelationshipsByFilterRequest.ProtoReflect.Descriptor instead.
func (*DeleteRelationshipsByFilterRequest) GetFilter ¶
func (x *DeleteRelationshipsByFilterRequest) GetFilter() *DeleteFilter
func (*DeleteRelationshipsByFilterRequest) ProtoMessage ¶
func (*DeleteRelationshipsByFilterRequest) ProtoMessage()
func (*DeleteRelationshipsByFilterRequest) ProtoReflect ¶
func (x *DeleteRelationshipsByFilterRequest) ProtoReflect() protoreflect.Message
func (*DeleteRelationshipsByFilterRequest) Reset ¶
func (x *DeleteRelationshipsByFilterRequest) Reset()
func (*DeleteRelationshipsByFilterRequest) String ¶
func (x *DeleteRelationshipsByFilterRequest) String() string
type DeleteRelationshipsByFilterResponse ¶
type DeleteRelationshipsByFilterResponse struct {
DeletedCount int64 `protobuf:"varint,1,opt,name=deleted_count,json=deletedCount,proto3" json:"deleted_count,omitempty"` // >= 0
// contains filtered or unexported fields
}
func (*DeleteRelationshipsByFilterResponse) Descriptor
deprecated
func (*DeleteRelationshipsByFilterResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRelationshipsByFilterResponse.ProtoReflect.Descriptor instead.
func (*DeleteRelationshipsByFilterResponse) GetDeletedCount ¶
func (x *DeleteRelationshipsByFilterResponse) GetDeletedCount() int64
func (*DeleteRelationshipsByFilterResponse) ProtoMessage ¶
func (*DeleteRelationshipsByFilterResponse) ProtoMessage()
func (*DeleteRelationshipsByFilterResponse) ProtoReflect ¶
func (x *DeleteRelationshipsByFilterResponse) ProtoReflect() protoreflect.Message
func (*DeleteRelationshipsByFilterResponse) Reset ¶
func (x *DeleteRelationshipsByFilterResponse) Reset()
func (*DeleteRelationshipsByFilterResponse) String ¶
func (x *DeleteRelationshipsByFilterResponse) String() string
type DeleteRelationshipsRequest ¶
type DeleteRelationshipsRequest struct {
Keys []*relationships.RelationshipKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` // empty list = no-op
// contains filtered or unexported fields
}
func (*DeleteRelationshipsRequest) Descriptor
deprecated
func (*DeleteRelationshipsRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRelationshipsRequest.ProtoReflect.Descriptor instead.
func (*DeleteRelationshipsRequest) GetKeys ¶
func (x *DeleteRelationshipsRequest) GetKeys() []*relationships.RelationshipKey
func (*DeleteRelationshipsRequest) ProtoMessage ¶
func (*DeleteRelationshipsRequest) ProtoMessage()
func (*DeleteRelationshipsRequest) ProtoReflect ¶
func (x *DeleteRelationshipsRequest) ProtoReflect() protoreflect.Message
func (*DeleteRelationshipsRequest) Reset ¶
func (x *DeleteRelationshipsRequest) Reset()
func (*DeleteRelationshipsRequest) String ¶
func (x *DeleteRelationshipsRequest) String() string
type DeleteRelationshipsResponse ¶
type DeleteRelationshipsResponse struct {
// contains filtered or unexported fields
}
func (*DeleteRelationshipsResponse) Descriptor
deprecated
func (*DeleteRelationshipsResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRelationshipsResponse.ProtoReflect.Descriptor instead.
func (*DeleteRelationshipsResponse) ProtoMessage ¶
func (*DeleteRelationshipsResponse) ProtoMessage()
func (*DeleteRelationshipsResponse) ProtoReflect ¶
func (x *DeleteRelationshipsResponse) ProtoReflect() protoreflect.Message
func (*DeleteRelationshipsResponse) Reset ¶
func (x *DeleteRelationshipsResponse) Reset()
func (*DeleteRelationshipsResponse) String ¶
func (x *DeleteRelationshipsResponse) String() string
type HealthRequest ¶
type HealthRequest struct {
// contains filtered or unexported fields
}
func (*HealthRequest) Descriptor
deprecated
func (*HealthRequest) Descriptor() ([]byte, []int)
Deprecated: Use HealthRequest.ProtoReflect.Descriptor instead.
func (*HealthRequest) ProtoMessage ¶
func (*HealthRequest) ProtoMessage()
func (*HealthRequest) ProtoReflect ¶
func (x *HealthRequest) ProtoReflect() protoreflect.Message
func (*HealthRequest) Reset ¶
func (x *HealthRequest) Reset()
func (*HealthRequest) String ¶
func (x *HealthRequest) String() string
type HealthResponse ¶
type HealthResponse struct {
Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
// contains filtered or unexported fields
}
func (*HealthResponse) Descriptor
deprecated
func (*HealthResponse) Descriptor() ([]byte, []int)
Deprecated: Use HealthResponse.ProtoReflect.Descriptor instead.
func (*HealthResponse) GetStatus ¶
func (x *HealthResponse) GetStatus() string
func (*HealthResponse) ProtoMessage ¶
func (*HealthResponse) ProtoMessage()
func (*HealthResponse) ProtoReflect ¶
func (x *HealthResponse) ProtoReflect() protoreflect.Message
func (*HealthResponse) Reset ¶
func (x *HealthResponse) Reset()
func (*HealthResponse) String ¶
func (x *HealthResponse) String() string
type UnimplementedUpdateServer ¶
type UnimplementedUpdateServer struct {
}
UnimplementedUpdateServer must be embedded to have forward compatible implementations.
func (UnimplementedUpdateServer) DeleteRelationships ¶
func (UnimplementedUpdateServer) DeleteRelationships(context.Context, *DeleteRelationshipsRequest) (*DeleteRelationshipsResponse, error)
func (UnimplementedUpdateServer) DeleteRelationshipsByFilter ¶
func (UnimplementedUpdateServer) DeleteRelationshipsByFilter(context.Context, *DeleteRelationshipsByFilterRequest) (*DeleteRelationshipsByFilterResponse, error)
func (UnimplementedUpdateServer) Health ¶
func (UnimplementedUpdateServer) Health(context.Context, *HealthRequest) (*HealthResponse, error)
func (UnimplementedUpdateServer) WriteRelationships ¶
func (UnimplementedUpdateServer) WriteRelationships(context.Context, *WriteRelationshipsRequest) (*WriteRelationshipsResponse, error)
type UnsafeUpdateServer ¶
type UnsafeUpdateServer interface {
// contains filtered or unexported methods
}
UnsafeUpdateServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UpdateServer will result in compilation errors.
type UpdateClient ¶
type UpdateClient interface {
Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
// Atomic upsert keyed by (subject, object, kind).
// Resolution failure on any input → NOT_FOUND, nothing written.
WriteRelationships(ctx context.Context, in *WriteRelationshipsRequest, opts ...grpc.CallOption) (*WriteRelationshipsResponse, error)
// Atomic, idempotent key-based delete.
// Resolution failure on any input → NOT_FOUND, nothing deleted.
DeleteRelationships(ctx context.Context, in *DeleteRelationshipsRequest, opts ...grpc.CallOption) (*DeleteRelationshipsResponse, error)
// Cascade delete by filter. Unscoped filter → INVALID_ARGUMENT.
// Separate from key-based delete to allow independent auth and rate-limiting.
DeleteRelationshipsByFilter(ctx context.Context, in *DeleteRelationshipsByFilterRequest, opts ...grpc.CallOption) (*DeleteRelationshipsByFilterResponse, error)
}
UpdateClient is the client API for Update 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 NewUpdateClient ¶
func NewUpdateClient(cc grpc.ClientConnInterface) UpdateClient
type UpdateServer ¶
type UpdateServer interface {
Health(context.Context, *HealthRequest) (*HealthResponse, error)
// Atomic upsert keyed by (subject, object, kind).
// Resolution failure on any input → NOT_FOUND, nothing written.
WriteRelationships(context.Context, *WriteRelationshipsRequest) (*WriteRelationshipsResponse, error)
// Atomic, idempotent key-based delete.
// Resolution failure on any input → NOT_FOUND, nothing deleted.
DeleteRelationships(context.Context, *DeleteRelationshipsRequest) (*DeleteRelationshipsResponse, error)
// Cascade delete by filter. Unscoped filter → INVALID_ARGUMENT.
// Separate from key-based delete to allow independent auth and rate-limiting.
DeleteRelationshipsByFilter(context.Context, *DeleteRelationshipsByFilterRequest) (*DeleteRelationshipsByFilterResponse, error)
// contains filtered or unexported methods
}
UpdateServer is the server API for Update service. All implementations must embed UnimplementedUpdateServer for forward compatibility
type WriteRelationshipsRequest ¶
type WriteRelationshipsRequest struct {
Relationships []*relationships.RelationshipInput `protobuf:"bytes,1,rep,name=relationships,proto3" json:"relationships,omitempty"` // required, non-empty
// contains filtered or unexported fields
}
func (*WriteRelationshipsRequest) Descriptor
deprecated
func (*WriteRelationshipsRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteRelationshipsRequest.ProtoReflect.Descriptor instead.
func (*WriteRelationshipsRequest) GetRelationships ¶
func (x *WriteRelationshipsRequest) GetRelationships() []*relationships.RelationshipInput
func (*WriteRelationshipsRequest) ProtoMessage ¶
func (*WriteRelationshipsRequest) ProtoMessage()
func (*WriteRelationshipsRequest) ProtoReflect ¶
func (x *WriteRelationshipsRequest) ProtoReflect() protoreflect.Message
func (*WriteRelationshipsRequest) Reset ¶
func (x *WriteRelationshipsRequest) Reset()
func (*WriteRelationshipsRequest) String ¶
func (x *WriteRelationshipsRequest) String() string
type WriteRelationshipsResponse ¶
type WriteRelationshipsResponse struct {
// Resolved tuples in input order, with assigned principals and timestamps.
Relationships []*relationships.Relationship `protobuf:"bytes,1,rep,name=relationships,proto3" json:"relationships,omitempty"`
// contains filtered or unexported fields
}
func (*WriteRelationshipsResponse) Descriptor
deprecated
func (*WriteRelationshipsResponse) Descriptor() ([]byte, []int)
Deprecated: Use WriteRelationshipsResponse.ProtoReflect.Descriptor instead.
func (*WriteRelationshipsResponse) GetRelationships ¶
func (x *WriteRelationshipsResponse) GetRelationships() []*relationships.Relationship
func (*WriteRelationshipsResponse) ProtoMessage ¶
func (*WriteRelationshipsResponse) ProtoMessage()
func (*WriteRelationshipsResponse) ProtoReflect ¶
func (x *WriteRelationshipsResponse) ProtoReflect() protoreflect.Message
func (*WriteRelationshipsResponse) Reset ¶
func (x *WriteRelationshipsResponse) Reset()
func (*WriteRelationshipsResponse) String ¶
func (x *WriteRelationshipsResponse) String() string