Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterResolverServer(s grpc.ServiceRegistrar, srv ResolverServer)
- func RegisterUpdaterServer(s grpc.ServiceRegistrar, srv UpdaterServer)
- type Key
- type ResolveTagRequest
- func (*ResolveTagRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResolveTagRequest) GetKey() *Key
- func (x *ResolveTagRequest) GetMinimumTimestamp() *timestamppb.Timestamp
- func (x *ResolveTagRequest) GetNamespace() *object.Namespace
- func (*ResolveTagRequest) ProtoMessage()
- func (x *ResolveTagRequest) ProtoReflect() protoreflect.Message
- func (x *ResolveTagRequest) Reset()
- func (x *ResolveTagRequest) String() string
- type ResolveTagResponse
- func (*ResolveTagResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ResolveTagResponse) GetComplete() bool
- func (x *ResolveTagResponse) GetSignedValue() *SignedValue
- func (*ResolveTagResponse) ProtoMessage()
- func (x *ResolveTagResponse) ProtoReflect() protoreflect.Message
- func (x *ResolveTagResponse) Reset()
- func (x *ResolveTagResponse) String() string
- type ResolverClient
- type ResolverServer
- type SignedValue
- func (*SignedValue) Descriptor() ([]byte, []int)deprecated
- func (x *SignedValue) GetSignature() []byte
- func (x *SignedValue) GetValue() *Value
- func (*SignedValue) ProtoMessage()
- func (x *SignedValue) ProtoReflect() protoreflect.Message
- func (x *SignedValue) Reset()
- func (x *SignedValue) String() string
- type UnimplementedResolverServer
- type UnimplementedUpdaterServer
- type UnsafeResolverServer
- type UnsafeUpdaterServer
- type UpdateTagRequest
- func (*UpdateTagRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateTagRequest) GetKey() *Key
- func (x *UpdateTagRequest) GetLease() []byte
- func (x *UpdateTagRequest) GetNamespace() *object.Namespace
- func (x *UpdateTagRequest) GetSignedValue() *SignedValue
- func (*UpdateTagRequest) ProtoMessage()
- func (x *UpdateTagRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateTagRequest) Reset()
- func (x *UpdateTagRequest) String() string
- type UpdaterClient
- type UpdaterServer
- type Value
- type ValueSigningInput
- func (*ValueSigningInput) Descriptor() ([]byte, []int)deprecated
- func (x *ValueSigningInput) GetKeyHash() []byte
- func (x *ValueSigningInput) GetReferenceFormat() object.ReferenceFormat_Value
- func (x *ValueSigningInput) GetValue() *Value
- func (*ValueSigningInput) ProtoMessage()
- func (x *ValueSigningInput) ProtoReflect() protoreflect.Message
- func (x *ValueSigningInput) Reset()
- func (x *ValueSigningInput) String() string
Constants ¶
const (
Resolver_ResolveTag_FullMethodName = "/bonanza.storage.tag.Resolver/ResolveTag"
)
const (
Updater_UpdateTag_FullMethodName = "/bonanza.storage.tag.Updater/UpdateTag"
)
Variables ¶
var File_bonanza_build_pkg_proto_storage_tag_tag_proto protoreflect.FileDescriptor
var Resolver_ServiceDesc = grpc.ServiceDesc{ ServiceName: "bonanza.storage.tag.Resolver", HandlerType: (*ResolverServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ResolveTag", Handler: _Resolver_ResolveTag_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "bonanza.build/pkg/proto/storage/tag/tag.proto", }
Resolver_ServiceDesc is the grpc.ServiceDesc for Resolver service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Updater_ServiceDesc = grpc.ServiceDesc{ ServiceName: "bonanza.storage.tag.Updater", HandlerType: (*UpdaterServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UpdateTag", Handler: _Updater_UpdateTag_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "bonanza.build/pkg/proto/storage/tag/tag.proto", }
Updater_ServiceDesc is the grpc.ServiceDesc for Updater service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterResolverServer ¶
func RegisterResolverServer(s grpc.ServiceRegistrar, srv ResolverServer)
func RegisterUpdaterServer ¶
func RegisterUpdaterServer(s grpc.ServiceRegistrar, srv UpdaterServer)
Types ¶
type Key ¶
type Key struct {
SignaturePublicKey []byte `protobuf:"bytes,1,opt,name=signature_public_key,json=signaturePublicKey,proto3" json:"signature_public_key,omitempty"`
Hash []byte `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
// contains filtered or unexported fields
}
func (*Key) Descriptor
deprecated
func (*Key) GetSignaturePublicKey ¶
func (*Key) ProtoMessage ¶
func (*Key) ProtoMessage()
func (*Key) ProtoReflect ¶
func (x *Key) ProtoReflect() protoreflect.Message
type ResolveTagRequest ¶
type ResolveTagRequest struct {
Namespace *object.Namespace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Key *Key `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
MinimumTimestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=minimum_timestamp,json=minimumTimestamp,proto3" json:"minimum_timestamp,omitempty"`
// contains filtered or unexported fields
}
func (*ResolveTagRequest) Descriptor
deprecated
func (*ResolveTagRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResolveTagRequest.ProtoReflect.Descriptor instead.
func (*ResolveTagRequest) GetKey ¶
func (x *ResolveTagRequest) GetKey() *Key
func (*ResolveTagRequest) GetMinimumTimestamp ¶
func (x *ResolveTagRequest) GetMinimumTimestamp() *timestamppb.Timestamp
func (*ResolveTagRequest) GetNamespace ¶
func (x *ResolveTagRequest) GetNamespace() *object.Namespace
func (*ResolveTagRequest) ProtoMessage ¶
func (*ResolveTagRequest) ProtoMessage()
func (*ResolveTagRequest) ProtoReflect ¶
func (x *ResolveTagRequest) ProtoReflect() protoreflect.Message
func (*ResolveTagRequest) Reset ¶
func (x *ResolveTagRequest) Reset()
func (*ResolveTagRequest) String ¶
func (x *ResolveTagRequest) String() string
type ResolveTagResponse ¶
type ResolveTagResponse struct {
SignedValue *SignedValue `protobuf:"bytes,1,opt,name=signed_value,json=signedValue,proto3" json:"signed_value,omitempty"`
Complete bool `protobuf:"varint,2,opt,name=complete,proto3" json:"complete,omitempty"`
// contains filtered or unexported fields
}
func (*ResolveTagResponse) Descriptor
deprecated
func (*ResolveTagResponse) Descriptor() ([]byte, []int)
Deprecated: Use ResolveTagResponse.ProtoReflect.Descriptor instead.
func (*ResolveTagResponse) GetComplete ¶
func (x *ResolveTagResponse) GetComplete() bool
func (*ResolveTagResponse) GetSignedValue ¶
func (x *ResolveTagResponse) GetSignedValue() *SignedValue
func (*ResolveTagResponse) ProtoMessage ¶
func (*ResolveTagResponse) ProtoMessage()
func (*ResolveTagResponse) ProtoReflect ¶
func (x *ResolveTagResponse) ProtoReflect() protoreflect.Message
func (*ResolveTagResponse) Reset ¶
func (x *ResolveTagResponse) Reset()
func (*ResolveTagResponse) String ¶
func (x *ResolveTagResponse) String() string
type ResolverClient ¶
type ResolverClient interface {
ResolveTag(ctx context.Context, in *ResolveTagRequest, opts ...grpc.CallOption) (*ResolveTagResponse, error)
}
ResolverClient is the client API for Resolver 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 NewResolverClient ¶
func NewResolverClient(cc grpc.ClientConnInterface) ResolverClient
type ResolverServer ¶
type ResolverServer interface {
ResolveTag(context.Context, *ResolveTagRequest) (*ResolveTagResponse, error)
}
ResolverServer is the server API for Resolver service. All implementations should embed UnimplementedResolverServer for forward compatibility.
type SignedValue ¶
type SignedValue struct {
Value *Value `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
// contains filtered or unexported fields
}
func (*SignedValue) Descriptor
deprecated
func (*SignedValue) Descriptor() ([]byte, []int)
Deprecated: Use SignedValue.ProtoReflect.Descriptor instead.
func (*SignedValue) GetSignature ¶
func (x *SignedValue) GetSignature() []byte
func (*SignedValue) GetValue ¶
func (x *SignedValue) GetValue() *Value
func (*SignedValue) ProtoMessage ¶
func (*SignedValue) ProtoMessage()
func (*SignedValue) ProtoReflect ¶
func (x *SignedValue) ProtoReflect() protoreflect.Message
func (*SignedValue) Reset ¶
func (x *SignedValue) Reset()
func (*SignedValue) String ¶
func (x *SignedValue) String() string
type UnimplementedResolverServer ¶
type UnimplementedResolverServer struct{}
UnimplementedResolverServer should 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 (UnimplementedResolverServer) ResolveTag ¶
func (UnimplementedResolverServer) ResolveTag(context.Context, *ResolveTagRequest) (*ResolveTagResponse, error)
type UnimplementedUpdaterServer ¶
type UnimplementedUpdaterServer struct{}
UnimplementedUpdaterServer should 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 (UnimplementedUpdaterServer) UpdateTag ¶
func (UnimplementedUpdaterServer) UpdateTag(context.Context, *UpdateTagRequest) (*emptypb.Empty, error)
type UnsafeResolverServer ¶
type UnsafeResolverServer interface {
// contains filtered or unexported methods
}
UnsafeResolverServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ResolverServer will result in compilation errors.
type UnsafeUpdaterServer ¶
type UnsafeUpdaterServer interface {
// contains filtered or unexported methods
}
UnsafeUpdaterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UpdaterServer will result in compilation errors.
type UpdateTagRequest ¶
type UpdateTagRequest struct {
Namespace *object.Namespace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Key *Key `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
SignedValue *SignedValue `protobuf:"bytes,3,opt,name=signed_value,json=signedValue,proto3" json:"signed_value,omitempty"`
Lease []byte `protobuf:"bytes,4,opt,name=lease,proto3" json:"lease,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateTagRequest) Descriptor
deprecated
func (*UpdateTagRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateTagRequest.ProtoReflect.Descriptor instead.
func (*UpdateTagRequest) GetKey ¶
func (x *UpdateTagRequest) GetKey() *Key
func (*UpdateTagRequest) GetLease ¶
func (x *UpdateTagRequest) GetLease() []byte
func (*UpdateTagRequest) GetNamespace ¶
func (x *UpdateTagRequest) GetNamespace() *object.Namespace
func (*UpdateTagRequest) GetSignedValue ¶
func (x *UpdateTagRequest) GetSignedValue() *SignedValue
func (*UpdateTagRequest) ProtoMessage ¶
func (*UpdateTagRequest) ProtoMessage()
func (*UpdateTagRequest) ProtoReflect ¶
func (x *UpdateTagRequest) ProtoReflect() protoreflect.Message
func (*UpdateTagRequest) Reset ¶
func (x *UpdateTagRequest) Reset()
func (*UpdateTagRequest) String ¶
func (x *UpdateTagRequest) String() string
type UpdaterClient ¶
type UpdaterClient interface {
UpdateTag(ctx context.Context, in *UpdateTagRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
UpdaterClient is the client API for Updater 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 NewUpdaterClient ¶
func NewUpdaterClient(cc grpc.ClientConnInterface) UpdaterClient
type UpdaterServer ¶
type UpdaterServer interface {
UpdateTag(context.Context, *UpdateTagRequest) (*emptypb.Empty, error)
}
UpdaterServer is the server API for Updater service. All implementations should embed UnimplementedUpdaterServer for forward compatibility.
type Value ¶
type Value struct {
Reference []byte `protobuf:"bytes,1,opt,name=reference,proto3" json:"reference,omitempty"`
Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// contains filtered or unexported fields
}
func (*Value) Descriptor
deprecated
func (*Value) GetReference ¶
func (*Value) GetTimestamp ¶
func (x *Value) GetTimestamp() *timestamppb.Timestamp
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) ProtoReflect ¶
func (x *Value) ProtoReflect() protoreflect.Message
type ValueSigningInput ¶
type ValueSigningInput struct {
ReferenceFormat object.ReferenceFormat_Value `` /* 157-byte string literal not displayed */
KeyHash []byte `protobuf:"bytes,2,opt,name=key_hash,json=keyHash,proto3" json:"key_hash,omitempty"`
Value *Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*ValueSigningInput) Descriptor
deprecated
func (*ValueSigningInput) Descriptor() ([]byte, []int)
Deprecated: Use ValueSigningInput.ProtoReflect.Descriptor instead.
func (*ValueSigningInput) GetKeyHash ¶
func (x *ValueSigningInput) GetKeyHash() []byte
func (*ValueSigningInput) GetReferenceFormat ¶
func (x *ValueSigningInput) GetReferenceFormat() object.ReferenceFormat_Value
func (*ValueSigningInput) GetValue ¶
func (x *ValueSigningInput) GetValue() *Value
func (*ValueSigningInput) ProtoMessage ¶
func (*ValueSigningInput) ProtoMessage()
func (*ValueSigningInput) ProtoReflect ¶
func (x *ValueSigningInput) ProtoReflect() protoreflect.Message
func (*ValueSigningInput) Reset ¶
func (x *ValueSigningInput) Reset()
func (*ValueSigningInput) String ¶
func (x *ValueSigningInput) String() string