proto

package
v0.0.0-...-680381e Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Discovery_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.Discovery",
	HandlerType: (*DiscoveryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FindPeers",
			Handler:    _Discovery_FindPeers_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "network/proto/discovery.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)

View Source 
var File_identity_proto protoreflect.FileDescriptor
View Source 
var File_network_proto_discovery_proto protoreflect.FileDescriptor
View Source 
var File_testing_proto protoreflect.FileDescriptor
View Source 
var Identity_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.Identity",
	HandlerType: (*IdentityServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Hello",
			Handler:    _Identity_Hello_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "identity.proto",
}

Identity_ServiceDesc is the grpc.ServiceDesc for Identity service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var TestService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.TestService",
	HandlerType: (*TestServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SayHello",
			Handler:    _TestService_SayHello_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetChattyServer",
			Handler:       _TestService_GetChattyServer_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetChattyClient",
			Handler:       _TestService_GetChattyClient_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "GetChattyBidi",
			Handler:       _TestService_GetChattyBidi_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "testing.proto",
}

TestService_ServiceDesc is the grpc.ServiceDesc for TestService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterDiscoveryServer 

func RegisterDiscoveryServer(s grpc.ServiceRegistrar, srv DiscoveryServer)

func RegisterIdentityServer 

func RegisterIdentityServer(s grpc.ServiceRegistrar, srv IdentityServer)

func RegisterTestServiceServer 

func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)

Types

type ChattyRequest 

type ChattyRequest struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Count   int32  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ChattyRequest) Descriptor deprecated 

func (*ChattyRequest) Descriptor() ([]byte, []int)

Deprecated: Use ChattyRequest.ProtoReflect.Descriptor instead.

func (*ChattyRequest) GetCount 

func (x *ChattyRequest) GetCount() int32

func (*ChattyRequest) GetMessage 

func (x *ChattyRequest) GetMessage() string

func (*ChattyRequest) ProtoMessage 

func (*ChattyRequest) ProtoMessage()

func (*ChattyRequest) ProtoReflect 

func (x *ChattyRequest) ProtoReflect() protoreflect.Message

func (*ChattyRequest) Reset 

func (x *ChattyRequest) Reset()

func (*ChattyRequest) String 

func (x *ChattyRequest) String() string

type DiscoveryClient 

type DiscoveryClient interface {
	FindPeers(ctx context.Context, in *FindPeersReq, opts ...grpc.CallOption) (*FindPeersResp, 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 {
	FindPeers(context.Context, *FindPeersReq) (*FindPeersResp, error)
	// contains filtered or unexported methods
}

DiscoveryServer is the server API for Discovery service. All implementations must embed UnimplementedDiscoveryServer for forward compatibility

type FindPeersReq 

type FindPeersReq struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Count int64  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*FindPeersReq) Descriptor deprecated 

func (*FindPeersReq) Descriptor() ([]byte, []int)

Deprecated: Use FindPeersReq.ProtoReflect.Descriptor instead.

func (*FindPeersReq) GetCount 

func (x *FindPeersReq) GetCount() int64

func (*FindPeersReq) GetKey 

func (x *FindPeersReq) GetKey() string

func (*FindPeersReq) ProtoMessage 

func (*FindPeersReq) ProtoMessage()

func (*FindPeersReq) ProtoReflect 

func (x *FindPeersReq) ProtoReflect() protoreflect.Message

func (*FindPeersReq) Reset 

func (x *FindPeersReq) Reset()

func (*FindPeersReq) String 

func (x *FindPeersReq) String() string

type FindPeersResp 

type FindPeersResp struct {
	Nodes []string `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*FindPeersResp) Descriptor deprecated 

func (*FindPeersResp) Descriptor() ([]byte, []int)

Deprecated: Use FindPeersResp.ProtoReflect.Descriptor instead.

func (*FindPeersResp) GetNodes 

func (x *FindPeersResp) GetNodes() []string

func (*FindPeersResp) ProtoMessage 

func (*FindPeersResp) ProtoMessage()

func (*FindPeersResp) ProtoReflect 

func (x *FindPeersResp) ProtoReflect() protoreflect.Message

func (*FindPeersResp) Reset 

func (x *FindPeersResp) Reset()

func (*FindPeersResp) String 

func (x *FindPeersResp) String() string

type GenericMessage 

type GenericMessage struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*GenericMessage) Descriptor deprecated 

func (*GenericMessage) Descriptor() ([]byte, []int)

Deprecated: Use GenericMessage.ProtoReflect.Descriptor instead.

func (*GenericMessage) GetMessage 

func (x *GenericMessage) GetMessage() string

func (*GenericMessage) ProtoMessage 

func (*GenericMessage) ProtoMessage()

func (*GenericMessage) ProtoReflect 

func (x *GenericMessage) ProtoReflect() protoreflect.Message

func (*GenericMessage) Reset 

func (x *GenericMessage) Reset()

func (*GenericMessage) String 

func (x *GenericMessage) String() string

type IdentityClient 

type IdentityClient interface {
	Hello(ctx context.Context, in *Status, opts ...grpc.CallOption) (*Status, error)
}

IdentityClient is the client API for Identity 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 NewIdentityClient 

func NewIdentityClient(cc grpc.ClientConnInterface) IdentityClient

type IdentityServer 

type IdentityServer interface {
	Hello(context.Context, *Status) (*Status, error)
	// contains filtered or unexported methods
}

IdentityServer is the server API for Identity service. All implementations must embed UnimplementedIdentityServer for forward compatibility

type Status 

type Status struct {
	Metadata      map[string]string `` /* 157-byte string literal not displayed */
	Keys          []*Status_Key     `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	Chain         int64             `protobuf:"varint,3,opt,name=chain,proto3" json:"chain,omitempty"`
	Genesis       string            `protobuf:"bytes,4,opt,name=genesis,proto3" json:"genesis,omitempty"`
	TemporaryDial bool              `protobuf:"varint,5,opt,name=temporaryDial,proto3" json:"temporaryDial,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

func (*Status) Descriptor() ([]byte, []int)

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetChain 

func (x *Status) GetChain() int64

func (*Status) GetGenesis 

func (x *Status) GetGenesis() string

func (*Status) GetKeys 

func (x *Status) GetKeys() []*Status_Key

func (*Status) GetMetadata 

func (x *Status) GetMetadata() map[string]string

func (*Status) GetTemporaryDial 

func (x *Status) GetTemporaryDial() bool

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

func (x *Status) ProtoReflect() protoreflect.Message

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type Status_Key 

type Status_Key struct {
	Signature string `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	Message   string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Status_Key) Descriptor deprecated 

func (*Status_Key) Descriptor() ([]byte, []int)

Deprecated: Use Status_Key.ProtoReflect.Descriptor instead.

func (*Status_Key) GetMessage 

func (x *Status_Key) GetMessage() string

func (*Status_Key) GetSignature 

func (x *Status_Key) GetSignature() string

func (*Status_Key) ProtoMessage 

func (*Status_Key) ProtoMessage()

func (*Status_Key) ProtoReflect 

func (x *Status_Key) ProtoReflect() protoreflect.Message

func (*Status_Key) Reset 

func (x *Status_Key) Reset()

func (*Status_Key) String 

func (x *Status_Key) String() string

type TestServiceClient 

type TestServiceClient interface {
	SayHello(ctx context.Context, in *GenericMessage, opts ...grpc.CallOption) (*GenericMessage, error)
	GetChattyServer(ctx context.Context, in *ChattyRequest, opts ...grpc.CallOption) (TestService_GetChattyServerClient, error)
	GetChattyClient(ctx context.Context, opts ...grpc.CallOption) (TestService_GetChattyClientClient, error)
	GetChattyBidi(ctx context.Context, opts ...grpc.CallOption) (TestService_GetChattyBidiClient, error)
}

TestServiceClient is the client API for TestService 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 NewTestServiceClient 

func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient

type TestServiceServer 

type TestServiceServer interface {
	SayHello(context.Context, *GenericMessage) (*GenericMessage, error)
	GetChattyServer(*ChattyRequest, TestService_GetChattyServerServer) error
	GetChattyClient(TestService_GetChattyClientServer) error
	GetChattyBidi(TestService_GetChattyBidiServer) error
	// contains filtered or unexported methods
}

TestServiceServer is the server API for TestService service. All implementations must embed UnimplementedTestServiceServer for forward compatibility

type TestService_GetChattyBidiClient 

type TestService_GetChattyBidiClient interface {
	Send(*GenericMessage) error
	Recv() (*GenericMessage, error)
	grpc.ClientStream
}

type TestService_GetChattyBidiServer 

type TestService_GetChattyBidiServer interface {
	Send(*GenericMessage) error
	Recv() (*GenericMessage, error)
	grpc.ServerStream
}

type TestService_GetChattyClientClient 

type TestService_GetChattyClientClient interface {
	Send(*GenericMessage) error
	CloseAndRecv() (*GenericMessage, error)
	grpc.ClientStream
}

type TestService_GetChattyClientServer 

type TestService_GetChattyClientServer interface {
	SendAndClose(*GenericMessage) error
	Recv() (*GenericMessage, error)
	grpc.ServerStream
}

type TestService_GetChattyServerClient 

type TestService_GetChattyServerClient interface {
	Recv() (*GenericMessage, error)
	grpc.ClientStream
}

type TestService_GetChattyServerServer 

type TestService_GetChattyServerServer interface {
	Send(*GenericMessage) error
	grpc.ServerStream
}

type UnimplementedDiscoveryServer 

type UnimplementedDiscoveryServer struct {
}

UnimplementedDiscoveryServer must be embedded to have forward compatible implementations.

func (UnimplementedDiscoveryServer) FindPeers 

func (UnimplementedDiscoveryServer) FindPeers(context.Context, *FindPeersReq) (*FindPeersResp, error)

type UnimplementedIdentityServer 

type UnimplementedIdentityServer struct {
}

UnimplementedIdentityServer must be embedded to have forward compatible implementations.

func (UnimplementedIdentityServer) Hello 

func (UnimplementedIdentityServer) Hello(context.Context, *Status) (*Status, error)

type UnimplementedTestServiceServer 

type UnimplementedTestServiceServer struct {
}

UnimplementedTestServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTestServiceServer) GetChattyBidi 

func (UnimplementedTestServiceServer) GetChattyBidi(TestService_GetChattyBidiServer) error

func (UnimplementedTestServiceServer) GetChattyClient 

func (UnimplementedTestServiceServer) GetChattyClient(TestService_GetChattyClientServer) error

func (UnimplementedTestServiceServer) GetChattyServer 

func (UnimplementedTestServiceServer) GetChattyServer(*ChattyRequest, TestService_GetChattyServerServer) error

func (UnimplementedTestServiceServer) SayHello 

func (UnimplementedTestServiceServer) SayHello(context.Context, *GenericMessage) (*GenericMessage, error)

type UnsafeDiscoveryServer 

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.

type UnsafeIdentityServer 

type UnsafeIdentityServer interface {
	// contains filtered or unexported methods
}

UnsafeIdentityServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IdentityServer will result in compilation errors.

type UnsafeTestServiceServer 

type UnsafeTestServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTestServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TestServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.