Documentation ¶
Index ¶
- Variables
- func RegisterDiscoveryServer(s grpc.ServiceRegistrar, srv DiscoveryServer)
- type Announce
- func (*Announce) Descriptor() ([]byte, []int)deprecated
- func (x *Announce) GetEndpoints() []string
- func (x *Announce) GetTai64() []byte
- func (x *Announce) GetTtlSeconds() int64
- func (*Announce) ProtoMessage()
- func (x *Announce) ProtoReflect() protoreflect.Message
- func (x *Announce) Reset()
- func (x *Announce) String() string
- type AnnounceReq
- func (*AnnounceReq) Descriptor() ([]byte, []int)deprecated
- func (x *AnnounceReq) GetAnnounce() []byte
- func (x *AnnounceReq) GetPublicKey() []byte
- func (x *AnnounceReq) GetSig() []byte
- func (*AnnounceReq) ProtoMessage()
- func (x *AnnounceReq) ProtoReflect() protoreflect.Message
- func (x *AnnounceReq) Reset()
- func (x *AnnounceReq) String() string
- type AnnounceRes
- type DiscoveryClient
- type DiscoveryServer
- type FindReq
- type FindRes
- func (*FindRes) Descriptor() ([]byte, []int)deprecated
- func (x *FindRes) GetAnnounce() []byte
- func (x *FindRes) GetPublicKey() []byte
- func (x *FindRes) GetSig() []byte
- func (*FindRes) ProtoMessage()
- func (x *FindRes) ProtoReflect() protoreflect.Message
- func (x *FindRes) Reset()
- func (x *FindRes) String() string
- type UnimplementedDiscoveryServer
- type UnsafeDiscoveryServer
Constants ¶
This section is empty.
Variables ¶
var Discovery_ServiceDesc = grpc.ServiceDesc{ ServiceName: "Discovery", HandlerType: (*DiscoveryServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Find", Handler: _Discovery_Find_Handler, }, { MethodName: "Announce", Handler: _Discovery_Announce_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "central.proto", }
Discovery_ServiceDesc is the grpc.ServiceDesc for Discovery service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_central_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDiscoveryServer ¶
func RegisterDiscoveryServer(s grpc.ServiceRegistrar, srv DiscoveryServer)
Types ¶
type Announce ¶
type Announce struct { Endpoints []string `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"` Tai64 []byte `protobuf:"bytes,2,opt,name=tai64,proto3" json:"tai64,omitempty"` TtlSeconds int64 `protobuf:"varint,3,opt,name=ttl_seconds,json=ttlSeconds,proto3" json:"ttl_seconds,omitempty"` // contains filtered or unexported fields }
func (*Announce) Descriptor
deprecated
func (*Announce) GetEndpoints ¶
func (*Announce) GetTtlSeconds ¶
func (*Announce) ProtoMessage ¶
func (*Announce) ProtoMessage()
func (*Announce) ProtoReflect ¶
func (x *Announce) ProtoReflect() protoreflect.Message
type AnnounceReq ¶
type AnnounceReq struct { PublicKey []byte `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` Announce []byte `protobuf:"bytes,2,opt,name=announce,proto3" json:"announce,omitempty"` Sig []byte `protobuf:"bytes,3,opt,name=sig,proto3" json:"sig,omitempty"` // contains filtered or unexported fields }
func (*AnnounceReq) Descriptor
deprecated
func (*AnnounceReq) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceReq.ProtoReflect.Descriptor instead.
func (*AnnounceReq) GetAnnounce ¶
func (x *AnnounceReq) GetAnnounce() []byte
func (*AnnounceReq) GetPublicKey ¶
func (x *AnnounceReq) GetPublicKey() []byte
func (*AnnounceReq) GetSig ¶
func (x *AnnounceReq) GetSig() []byte
func (*AnnounceReq) ProtoMessage ¶
func (*AnnounceReq) ProtoMessage()
func (*AnnounceReq) ProtoReflect ¶
func (x *AnnounceReq) ProtoReflect() protoreflect.Message
func (*AnnounceReq) Reset ¶
func (x *AnnounceReq) Reset()
func (*AnnounceReq) String ¶
func (x *AnnounceReq) String() string
type AnnounceRes ¶
type AnnounceRes struct {
// contains filtered or unexported fields
}
func (*AnnounceRes) Descriptor
deprecated
func (*AnnounceRes) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceRes.ProtoReflect.Descriptor instead.
func (*AnnounceRes) ProtoMessage ¶
func (*AnnounceRes) ProtoMessage()
func (*AnnounceRes) ProtoReflect ¶
func (x *AnnounceRes) ProtoReflect() protoreflect.Message
func (*AnnounceRes) Reset ¶
func (x *AnnounceRes) Reset()
func (*AnnounceRes) String ¶
func (x *AnnounceRes) String() string
type DiscoveryClient ¶
type DiscoveryClient interface { Find(ctx context.Context, in *FindReq, opts ...grpc.CallOption) (*FindRes, error) Announce(ctx context.Context, in *AnnounceReq, opts ...grpc.CallOption) (*AnnounceRes, error) }
DiscoveryClient is the client API for Discovery 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 NewDiscoveryClient ¶
func NewDiscoveryClient(cc grpc.ClientConnInterface) DiscoveryClient
type DiscoveryServer ¶
type DiscoveryServer interface { Find(context.Context, *FindReq) (*FindRes, error) Announce(context.Context, *AnnounceReq) (*AnnounceRes, error) // contains filtered or unexported methods }
DiscoveryServer is the server API for Discovery service. All implementations must embed UnimplementedDiscoveryServer for forward compatibility
type FindReq ¶
type FindReq struct { Target []byte `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` // contains filtered or unexported fields }
func (*FindReq) Descriptor
deprecated
func (*FindReq) ProtoMessage ¶
func (*FindReq) ProtoMessage()
func (*FindReq) ProtoReflect ¶
func (x *FindReq) ProtoReflect() protoreflect.Message
type FindRes ¶
type FindRes struct { PublicKey []byte `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` Announce []byte `protobuf:"bytes,2,opt,name=announce,proto3" json:"announce,omitempty"` Sig []byte `protobuf:"bytes,3,opt,name=sig,proto3" json:"sig,omitempty"` // contains filtered or unexported fields }
func (*FindRes) Descriptor
deprecated
func (*FindRes) GetAnnounce ¶
func (*FindRes) GetPublicKey ¶
func (*FindRes) ProtoMessage ¶
func (*FindRes) ProtoMessage()
func (*FindRes) ProtoReflect ¶
func (x *FindRes) ProtoReflect() protoreflect.Message
type UnimplementedDiscoveryServer ¶
type UnimplementedDiscoveryServer struct { }
UnimplementedDiscoveryServer must be embedded to have forward compatible implementations.
func (UnimplementedDiscoveryServer) Announce ¶
func (UnimplementedDiscoveryServer) Announce(context.Context, *AnnounceReq) (*AnnounceRes, error)
type UnsafeDiscoveryServer ¶ added in v0.0.5
type UnsafeDiscoveryServer interface {
// contains filtered or unexported methods
}
UnsafeDiscoveryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DiscoveryServer will result in compilation errors.