update

package
v1.0.8 Latest Latest
Warning

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

Go to latest
Published: Jun 2, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_proto_update_update_proto protoreflect.FileDescriptor
View Source
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 (*DeleteRelationshipsByFilterRequest) ProtoMessage

func (*DeleteRelationshipsByFilterRequest) ProtoMessage()

func (*DeleteRelationshipsByFilterRequest) ProtoReflect

func (*DeleteRelationshipsByFilterRequest) Reset

func (*DeleteRelationshipsByFilterRequest) 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 (*DeleteRelationshipsByFilterResponse) Reset

func (*DeleteRelationshipsByFilterResponse) 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 (*DeleteRelationshipsRequest) ProtoMessage

func (*DeleteRelationshipsRequest) ProtoMessage()

func (*DeleteRelationshipsRequest) ProtoReflect

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 (*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) Health

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 (*WriteRelationshipsRequest) ProtoMessage

func (*WriteRelationshipsRequest) ProtoMessage()

func (*WriteRelationshipsRequest) ProtoReflect

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 (*WriteRelationshipsResponse) Reset

func (x *WriteRelationshipsResponse) Reset()

func (*WriteRelationshipsResponse) String

func (x *WriteRelationshipsResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL