proto

package
v0.0.0-...-231e548 Latest Latest
Warning

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

Go to latest
Published: Jan 25, 2024 License: Apache-2.0 Imports: 21 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_network_proto_discovery_proto protoreflect.FileDescriptor
View Source
var File_network_proto_identity_proto protoreflect.FileDescriptor
View Source
var File_network_proto_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: "network/proto/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: "network/proto/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

func (*ChattyRequest) Validate

func (m *ChattyRequest) Validate() error

Validate checks the field values on ChattyRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ChattyRequest) ValidateAll

func (m *ChattyRequest) ValidateAll() error

ValidateAll checks the field values on ChattyRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ChattyRequestMultiError, or nil if none found.

type ChattyRequestMultiError

type ChattyRequestMultiError []error

ChattyRequestMultiError is an error wrapping multiple validation errors returned by ChattyRequest.ValidateAll() if the designated constraints aren't met.

func (ChattyRequestMultiError) AllErrors

func (m ChattyRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ChattyRequestMultiError) Error

func (m ChattyRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ChattyRequestValidationError

type ChattyRequestValidationError struct {
	// contains filtered or unexported fields
}

ChattyRequestValidationError is the validation error returned by ChattyRequest.Validate if the designated constraints aren't met.

func (ChattyRequestValidationError) Cause

Cause function returns cause value.

func (ChattyRequestValidationError) Error

Error satisfies the builtin error interface

func (ChattyRequestValidationError) ErrorName

func (e ChattyRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ChattyRequestValidationError) Field

Field function returns field value.

func (ChattyRequestValidationError) Key

Key function returns key value.

func (ChattyRequestValidationError) Reason

Reason function returns reason value.

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"` // network/discovery/discovery.go => maxDiscoveryPeerReqCount
	// 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

func (*FindPeersReq) Validate

func (m *FindPeersReq) Validate() error

Validate checks the field values on FindPeersReq with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*FindPeersReq) ValidateAll

func (m *FindPeersReq) ValidateAll() error

ValidateAll checks the field values on FindPeersReq with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in FindPeersReqMultiError, or nil if none found.

type FindPeersReqMultiError

type FindPeersReqMultiError []error

FindPeersReqMultiError is an error wrapping multiple validation errors returned by FindPeersReq.ValidateAll() if the designated constraints aren't met.

func (FindPeersReqMultiError) AllErrors

func (m FindPeersReqMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FindPeersReqMultiError) Error

func (m FindPeersReqMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type FindPeersReqValidationError

type FindPeersReqValidationError struct {
	// contains filtered or unexported fields
}

FindPeersReqValidationError is the validation error returned by FindPeersReq.Validate if the designated constraints aren't met.

func (FindPeersReqValidationError) Cause

Cause function returns cause value.

func (FindPeersReqValidationError) Error

Error satisfies the builtin error interface

func (FindPeersReqValidationError) ErrorName

func (e FindPeersReqValidationError) ErrorName() string

ErrorName returns error name.

func (FindPeersReqValidationError) Field

Field function returns field value.

func (FindPeersReqValidationError) Key

Key function returns key value.

func (FindPeersReqValidationError) Reason

Reason function returns reason value.

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

func (*FindPeersResp) Validate

func (m *FindPeersResp) Validate() error

Validate checks the field values on FindPeersResp with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*FindPeersResp) ValidateAll

func (m *FindPeersResp) ValidateAll() error

ValidateAll checks the field values on FindPeersResp with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in FindPeersRespMultiError, or nil if none found.

type FindPeersRespMultiError

type FindPeersRespMultiError []error

FindPeersRespMultiError is an error wrapping multiple validation errors returned by FindPeersResp.ValidateAll() if the designated constraints aren't met.

func (FindPeersRespMultiError) AllErrors

func (m FindPeersRespMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FindPeersRespMultiError) Error

func (m FindPeersRespMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type FindPeersRespValidationError

type FindPeersRespValidationError struct {
	// contains filtered or unexported fields
}

FindPeersRespValidationError is the validation error returned by FindPeersResp.Validate if the designated constraints aren't met.

func (FindPeersRespValidationError) Cause

Cause function returns cause value.

func (FindPeersRespValidationError) Error

Error satisfies the builtin error interface

func (FindPeersRespValidationError) ErrorName

func (e FindPeersRespValidationError) ErrorName() string

ErrorName returns error name.

func (FindPeersRespValidationError) Field

Field function returns field value.

func (FindPeersRespValidationError) Key

Key function returns key value.

func (FindPeersRespValidationError) Reason

Reason function returns reason value.

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

func (*GenericMessage) Validate

func (m *GenericMessage) Validate() error

Validate checks the field values on GenericMessage with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GenericMessage) ValidateAll

func (m *GenericMessage) ValidateAll() error

ValidateAll checks the field values on GenericMessage with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GenericMessageMultiError, or nil if none found.

type GenericMessageMultiError

type GenericMessageMultiError []error

GenericMessageMultiError is an error wrapping multiple validation errors returned by GenericMessage.ValidateAll() if the designated constraints aren't met.

func (GenericMessageMultiError) AllErrors

func (m GenericMessageMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GenericMessageMultiError) Error

func (m GenericMessageMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GenericMessageValidationError

type GenericMessageValidationError struct {
	// contains filtered or unexported fields
}

GenericMessageValidationError is the validation error returned by GenericMessage.Validate if the designated constraints aren't met.

func (GenericMessageValidationError) Cause

Cause function returns cause value.

func (GenericMessageValidationError) Error

Error satisfies the builtin error interface

func (GenericMessageValidationError) ErrorName

func (e GenericMessageValidationError) ErrorName() string

ErrorName returns error name.

func (GenericMessageValidationError) Field

Field function returns field value.

func (GenericMessageValidationError) Key

Key function returns key value.

func (GenericMessageValidationError) Reason

Reason function returns reason value.

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

func (*Status) Validate

func (m *Status) Validate() error

Validate checks the field values on Status with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Status) ValidateAll

func (m *Status) ValidateAll() error

ValidateAll checks the field values on Status with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StatusMultiError, or nil if none found.

type StatusMultiError

type StatusMultiError []error

StatusMultiError is an error wrapping multiple validation errors returned by Status.ValidateAll() if the designated constraints aren't met.

func (StatusMultiError) AllErrors

func (m StatusMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StatusMultiError) Error

func (m StatusMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type StatusValidationError

type StatusValidationError struct {
	// contains filtered or unexported fields
}

StatusValidationError is the validation error returned by Status.Validate if the designated constraints aren't met.

func (StatusValidationError) Cause

func (e StatusValidationError) Cause() error

Cause function returns cause value.

func (StatusValidationError) Error

func (e StatusValidationError) Error() string

Error satisfies the builtin error interface

func (StatusValidationError) ErrorName

func (e StatusValidationError) ErrorName() string

ErrorName returns error name.

func (StatusValidationError) Field

func (e StatusValidationError) Field() string

Field function returns field value.

func (StatusValidationError) Key

func (e StatusValidationError) Key() bool

Key function returns key value.

func (StatusValidationError) Reason

func (e StatusValidationError) Reason() string

Reason function returns reason value.

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

func (*Status_Key) Validate

func (m *Status_Key) Validate() error

Validate checks the field values on Status_Key with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Status_Key) ValidateAll

func (m *Status_Key) ValidateAll() error

ValidateAll checks the field values on Status_Key with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in Status_KeyMultiError, or nil if none found.

type Status_KeyMultiError

type Status_KeyMultiError []error

Status_KeyMultiError is an error wrapping multiple validation errors returned by Status_Key.ValidateAll() if the designated constraints aren't met.

func (Status_KeyMultiError) AllErrors

func (m Status_KeyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (Status_KeyMultiError) Error

func (m Status_KeyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type Status_KeyValidationError

type Status_KeyValidationError struct {
	// contains filtered or unexported fields
}

Status_KeyValidationError is the validation error returned by Status_Key.Validate if the designated constraints aren't met.

func (Status_KeyValidationError) Cause

func (e Status_KeyValidationError) Cause() error

Cause function returns cause value.

func (Status_KeyValidationError) Error

Error satisfies the builtin error interface

func (Status_KeyValidationError) ErrorName

func (e Status_KeyValidationError) ErrorName() string

ErrorName returns error name.

func (Status_KeyValidationError) Field

Field function returns field value.

func (Status_KeyValidationError) Key

Key function returns key value.

func (Status_KeyValidationError) Reason

func (e Status_KeyValidationError) Reason() string

Reason function returns reason value.

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