talos_testproto

package
v0.3.1 Latest Latest
Warning

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

Go to latest
Published: Jun 6, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var MultiService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "talos.testproto.MultiService",
	HandlerType: (*MultiServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PingEmpty",
			Handler:    _MultiService_PingEmpty_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _MultiService_Ping_Handler,
		},
		{
			MethodName: "PingError",
			Handler:    _MultiService_PingError_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PingList",
			Handler:       _MultiService_PingList_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "PingStream",
			Handler:       _MultiService_PingStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "PingStreamError",
			Handler:       _MultiService_PingStreamError_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "test.proto",
}

MultiService_ServiceDesc is the grpc.ServiceDesc for MultiService 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: "talos.testproto.TestService",
	HandlerType: (*TestServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PingEmpty",
			Handler:    _TestService_PingEmpty_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _TestService_Ping_Handler,
		},
		{
			MethodName: "PingError",
			Handler:    _TestService_PingError_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PingList",
			Handler:       _TestService_PingList_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "PingStream",
			Handler:       _TestService_PingStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "test.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 RegisterMultiServiceServer

func RegisterMultiServiceServer(s grpc.ServiceRegistrar, srv MultiServiceServer)

func RegisterTestServiceServer

func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)

Types

type Empty

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

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect added in v0.3.0

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type EmptyReply

type EmptyReply struct {
	Response []*EmptyResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*EmptyReply) Descriptor deprecated

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

Deprecated: Use EmptyReply.ProtoReflect.Descriptor instead.

func (*EmptyReply) GetResponse

func (x *EmptyReply) GetResponse() []*EmptyResponse

func (*EmptyReply) ProtoMessage

func (*EmptyReply) ProtoMessage()

func (*EmptyReply) ProtoReflect added in v0.3.0

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

func (*EmptyReply) Reset

func (x *EmptyReply) Reset()

func (*EmptyReply) String

func (x *EmptyReply) String() string

type EmptyResponse

type EmptyResponse struct {
	Metadata *ResponseMetadata `protobuf:"bytes,99,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*EmptyResponse) Descriptor deprecated

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

Deprecated: Use EmptyResponse.ProtoReflect.Descriptor instead.

func (*EmptyResponse) GetMetadata

func (x *EmptyResponse) GetMetadata() *ResponseMetadata

func (*EmptyResponse) ProtoMessage

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) ProtoReflect added in v0.3.0

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

func (*EmptyResponse) Reset

func (x *EmptyResponse) Reset()

func (*EmptyResponse) String

func (x *EmptyResponse) String() string

type MultiPingReply

type MultiPingReply struct {
	Response []*MultiPingResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiPingReply) Descriptor deprecated

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

Deprecated: Use MultiPingReply.ProtoReflect.Descriptor instead.

func (*MultiPingReply) GetResponse

func (x *MultiPingReply) GetResponse() []*MultiPingResponse

func (*MultiPingReply) ProtoMessage

func (*MultiPingReply) ProtoMessage()

func (*MultiPingReply) ProtoReflect added in v0.3.0

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

func (*MultiPingReply) Reset

func (x *MultiPingReply) Reset()

func (*MultiPingReply) String

func (x *MultiPingReply) String() string

type MultiPingResponse

type MultiPingResponse struct {
	Metadata *ResponseMetadata `protobuf:"bytes,99,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Value    string            `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
	Counter  int32             `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`
	Server   string            `protobuf:"bytes,3,opt,name=server,proto3" json:"server,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiPingResponse) Descriptor deprecated

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

Deprecated: Use MultiPingResponse.ProtoReflect.Descriptor instead.

func (*MultiPingResponse) GetCounter

func (x *MultiPingResponse) GetCounter() int32

func (*MultiPingResponse) GetMetadata

func (x *MultiPingResponse) GetMetadata() *ResponseMetadata

func (*MultiPingResponse) GetServer

func (x *MultiPingResponse) GetServer() string

func (*MultiPingResponse) GetValue

func (x *MultiPingResponse) GetValue() string

func (*MultiPingResponse) ProtoMessage

func (*MultiPingResponse) ProtoMessage()

func (*MultiPingResponse) ProtoReflect added in v0.3.0

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

func (*MultiPingResponse) Reset

func (x *MultiPingResponse) Reset()

func (*MultiPingResponse) String

func (x *MultiPingResponse) String() string

type MultiServiceClient

type MultiServiceClient interface {
	PingEmpty(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*MultiPingReply, error)
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*MultiPingReply, error)
	PingError(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*EmptyReply, error)
	PingList(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (MultiService_PingListClient, error)
	PingStream(ctx context.Context, opts ...grpc.CallOption) (MultiService_PingStreamClient, error)
	PingStreamError(ctx context.Context, opts ...grpc.CallOption) (MultiService_PingStreamErrorClient, error)
}

MultiServiceClient is the client API for MultiService 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 MultiServiceServer

type MultiServiceServer interface {
	PingEmpty(context.Context, *Empty) (*MultiPingReply, error)
	Ping(context.Context, *PingRequest) (*MultiPingReply, error)
	PingError(context.Context, *PingRequest) (*EmptyReply, error)
	PingList(*PingRequest, MultiService_PingListServer) error
	PingStream(MultiService_PingStreamServer) error
	PingStreamError(MultiService_PingStreamErrorServer) error
	// contains filtered or unexported methods
}

MultiServiceServer is the server API for MultiService service. All implementations must embed UnimplementedMultiServiceServer for forward compatibility

type MultiService_PingListClient

type MultiService_PingListClient interface {
	Recv() (*MultiPingResponse, error)
	grpc.ClientStream
}

type MultiService_PingListServer

type MultiService_PingListServer interface {
	Send(*MultiPingResponse) error
	grpc.ServerStream
}

type MultiService_PingStreamClient

type MultiService_PingStreamClient interface {
	Send(*PingRequest) error
	Recv() (*MultiPingResponse, error)
	grpc.ClientStream
}

type MultiService_PingStreamErrorClient

type MultiService_PingStreamErrorClient interface {
	Send(*PingRequest) error
	Recv() (*MultiPingResponse, error)
	grpc.ClientStream
}

type MultiService_PingStreamErrorServer

type MultiService_PingStreamErrorServer interface {
	Send(*MultiPingResponse) error
	Recv() (*PingRequest, error)
	grpc.ServerStream
}

type MultiService_PingStreamServer

type MultiService_PingStreamServer interface {
	Send(*MultiPingResponse) error
	Recv() (*PingRequest, error)
	grpc.ServerStream
}

type PingRequest

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

func (*PingRequest) Descriptor deprecated

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetValue

func (x *PingRequest) GetValue() string

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect added in v0.3.0

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

func (*PingRequest) Reset

func (x *PingRequest) Reset()

func (*PingRequest) String

func (x *PingRequest) String() string

type PingResponse

type PingResponse struct {
	Value   string `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
	Counter int32  `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetCounter

func (x *PingResponse) GetCounter() int32

func (*PingResponse) GetValue

func (x *PingResponse) GetValue() string

func (*PingResponse) ProtoMessage

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect added in v0.3.0

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

func (*PingResponse) Reset

func (x *PingResponse) Reset()

func (*PingResponse) String

func (x *PingResponse) String() string

type ResponseMetadata

type ResponseMetadata struct {
	Hostname      string `protobuf:"bytes,99,opt,name=hostname,proto3" json:"hostname,omitempty"`
	UpstreamError string `protobuf:"bytes,100,opt,name=upstream_error,json=upstreamError,proto3" json:"upstream_error,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseMetadata) Descriptor deprecated

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

Deprecated: Use ResponseMetadata.ProtoReflect.Descriptor instead.

func (*ResponseMetadata) GetHostname

func (x *ResponseMetadata) GetHostname() string

func (*ResponseMetadata) GetUpstreamError

func (x *ResponseMetadata) GetUpstreamError() string

func (*ResponseMetadata) ProtoMessage

func (*ResponseMetadata) ProtoMessage()

func (*ResponseMetadata) ProtoReflect added in v0.3.0

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

func (*ResponseMetadata) Reset

func (x *ResponseMetadata) Reset()

func (*ResponseMetadata) String

func (x *ResponseMetadata) String() string

type ResponseMetadataPrepender

type ResponseMetadataPrepender struct {
	Metadata *ResponseMetadata `protobuf:"bytes,99,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseMetadataPrepender) Descriptor deprecated

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

Deprecated: Use ResponseMetadataPrepender.ProtoReflect.Descriptor instead.

func (*ResponseMetadataPrepender) GetMetadata

func (x *ResponseMetadataPrepender) GetMetadata() *ResponseMetadata

func (*ResponseMetadataPrepender) ProtoMessage

func (*ResponseMetadataPrepender) ProtoMessage()

func (*ResponseMetadataPrepender) ProtoReflect added in v0.3.0

func (*ResponseMetadataPrepender) Reset

func (x *ResponseMetadataPrepender) Reset()

func (*ResponseMetadataPrepender) String

func (x *ResponseMetadataPrepender) String() string

type TestServiceClient

type TestServiceClient interface {
	PingEmpty(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PingResponse, error)
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	PingError(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*Empty, error)
	PingList(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (TestService_PingListClient, error)
	PingStream(ctx context.Context, opts ...grpc.CallOption) (TestService_PingStreamClient, 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 {
	PingEmpty(context.Context, *Empty) (*PingResponse, error)
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	PingError(context.Context, *PingRequest) (*Empty, error)
	PingList(*PingRequest, TestService_PingListServer) error
	PingStream(TestService_PingStreamServer) error
	// contains filtered or unexported methods
}

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

type TestService_PingListClient

type TestService_PingListClient interface {
	Recv() (*PingResponse, error)
	grpc.ClientStream
}

type TestService_PingListServer

type TestService_PingListServer interface {
	Send(*PingResponse) error
	grpc.ServerStream
}

type TestService_PingStreamClient

type TestService_PingStreamClient interface {
	Send(*PingRequest) error
	Recv() (*PingResponse, error)
	grpc.ClientStream
}

type TestService_PingStreamServer

type TestService_PingStreamServer interface {
	Send(*PingResponse) error
	Recv() (*PingRequest, error)
	grpc.ServerStream
}

type UnimplementedMultiServiceServer

type UnimplementedMultiServiceServer struct{}

UnimplementedMultiServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMultiServiceServer) Ping

func (UnimplementedMultiServiceServer) PingEmpty

func (UnimplementedMultiServiceServer) PingError

func (UnimplementedMultiServiceServer) PingList

func (UnimplementedMultiServiceServer) PingStream

func (UnimplementedMultiServiceServer) PingStreamError

type UnimplementedTestServiceServer

type UnimplementedTestServiceServer struct{}

UnimplementedTestServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTestServiceServer) Ping

func (UnimplementedTestServiceServer) PingEmpty

func (UnimplementedTestServiceServer) PingError

func (UnimplementedTestServiceServer) PingList

func (UnimplementedTestServiceServer) PingStream

type UnsafeMultiServiceServer added in v0.3.0

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

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

type UnsafeTestServiceServer added in v0.3.0

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