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.

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

type UnimplementedIdentityServer

type UnimplementedIdentityServer struct {
}

UnimplementedIdentityServer must be embedded to have forward compatible implementations.

func (UnimplementedIdentityServer) Hello

type UnimplementedTestServiceServer

type UnimplementedTestServiceServer struct {
}

UnimplementedTestServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTestServiceServer) GetChattyBidi

func (UnimplementedTestServiceServer) GetChattyClient

func (UnimplementedTestServiceServer) GetChattyServer

func (UnimplementedTestServiceServer) SayHello

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.

Jump to

Keyboard shortcuts

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