test

package
v1.2.1 Latest Latest
Warning

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

Go to latest
Published: Sep 13, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Decrement_Dec_FullMethodName = "/test.Decrement/Dec"
)
View Source
const (
	Echo_Echo_FullMethodName = "/test.Echo/Echo"
)
View Source
const (
	Error_Error_FullMethodName = "/test.Error/Error"
)
View Source
const (
	Hash_Hash_FullMethodName = "/test.Hash/Hash"
)
View Source
const (
	Increment_Inc_FullMethodName = "/test.Increment/Inc"
)
View Source
const (
	Multiply_Mul_FullMethodName = "/test.Multiply/Mul"
)
View Source
const (
	Notify_Notify_FullMethodName = "/test.Notify/Notify"
)
View Source
const (
	Sleep_Sleep_FullMethodName = "/test.Sleep/Sleep"
)
View Source
const (
	Test_TestStream_FullMethodName = "/test.Test/TestStream"
)

Variables

View Source
var Decrement_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "test.Decrement",
	HandlerType: (*DecrementServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Dec",
			Handler:    _Decrement_Dec_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/kralicky/totem/test/test.proto",
}

Decrement_ServiceDesc is the grpc.ServiceDesc for Decrement 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 Echo_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "test.Echo",
	HandlerType: (*EchoServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Echo",
			Handler:    _Echo_Echo_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/kralicky/totem/test/test.proto",
}

Echo_ServiceDesc is the grpc.ServiceDesc for Echo 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 Error_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "test.Error",
	HandlerType: (*ErrorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Error",
			Handler:    _Error_Error_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/kralicky/totem/test/test.proto",
}

Error_ServiceDesc is the grpc.ServiceDesc for Error 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_github_com_kralicky_totem_test_test_proto protoreflect.FileDescriptor
View Source
var Hash_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "test.Hash",
	HandlerType: (*HashServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Hash",
			Handler:    _Hash_Hash_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/kralicky/totem/test/test.proto",
}

Hash_ServiceDesc is the grpc.ServiceDesc for Hash 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 Increment_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "test.Increment",
	HandlerType: (*IncrementServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Inc",
			Handler:    _Increment_Inc_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/kralicky/totem/test/test.proto",
}

Increment_ServiceDesc is the grpc.ServiceDesc for Increment 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 Multiply_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "test.Multiply",
	HandlerType: (*MultiplyServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Mul",
			Handler:    _Multiply_Mul_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/kralicky/totem/test/test.proto",
}

Multiply_ServiceDesc is the grpc.ServiceDesc for Multiply 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 Notify_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "test.Notify",
	HandlerType: (*NotifyServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Notify",
			Handler:    _Notify_Notify_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/kralicky/totem/test/test.proto",
}

Notify_ServiceDesc is the grpc.ServiceDesc for Notify 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 Sleep_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "test.Sleep",
	HandlerType: (*SleepServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Sleep",
			Handler:    _Sleep_Sleep_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/kralicky/totem/test/test.proto",
}

Sleep_ServiceDesc is the grpc.ServiceDesc for Sleep 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 Test_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "test.Test",
	HandlerType: (*TestServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "TestStream",
			Handler:       _Test_TestStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "github.com/kralicky/totem/test/test.proto",
}

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

Functions

func RegisterDecrementServer

func RegisterDecrementServer(s grpc.ServiceRegistrar, srv DecrementServer)

func RegisterEchoServer added in v1.1.14

func RegisterEchoServer(s grpc.ServiceRegistrar, srv EchoServer)

func RegisterErrorServer

func RegisterErrorServer(s grpc.ServiceRegistrar, srv ErrorServer)

func RegisterHashServer

func RegisterHashServer(s grpc.ServiceRegistrar, srv HashServer)

func RegisterIncrementServer

func RegisterIncrementServer(s grpc.ServiceRegistrar, srv IncrementServer)

func RegisterMultiplyServer added in v1.1.14

func RegisterMultiplyServer(s grpc.ServiceRegistrar, srv MultiplyServer)

func RegisterNotifyServer added in v1.1.14

func RegisterNotifyServer(s grpc.ServiceRegistrar, srv NotifyServer)

func RegisterSleepServer added in v1.1.14

func RegisterSleepServer(s grpc.ServiceRegistrar, srv SleepServer)

func RegisterTestServer

func RegisterTestServer(s grpc.ServiceRegistrar, srv TestServer)

Types

type Bytes added in v1.1.14

type Bytes struct {
	Data []byte `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

func (*Bytes) Descriptor deprecated added in v1.1.14

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

Deprecated: Use Bytes.ProtoReflect.Descriptor instead.

func (*Bytes) GetData added in v1.1.14

func (x *Bytes) GetData() []byte

func (*Bytes) ProtoMessage added in v1.1.14

func (*Bytes) ProtoMessage()

func (*Bytes) ProtoReflect added in v1.1.14

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

func (*Bytes) Reset added in v1.1.14

func (x *Bytes) Reset()

func (*Bytes) String added in v1.1.14

func (x *Bytes) String() string

type DecrementClient

type DecrementClient interface {
	Dec(ctx context.Context, in *Number, opts ...grpc.CallOption) (*Number, error)
}

DecrementClient is the client API for Decrement 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 NewDecrementClient

func NewDecrementClient(cc grpc.ClientConnInterface) DecrementClient

type DecrementServer

type DecrementServer interface {
	Dec(context.Context, *Number) (*Number, error)
	// contains filtered or unexported methods
}

DecrementServer is the server API for Decrement service. All implementations must embed UnimplementedDecrementServer for forward compatibility

type EchoClient added in v1.1.14

type EchoClient interface {
	Echo(ctx context.Context, in *Bytes, opts ...grpc.CallOption) (*Bytes, error)
}

EchoClient is the client API for Echo 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 NewEchoClient added in v1.1.14

func NewEchoClient(cc grpc.ClientConnInterface) EchoClient

type EchoServer added in v1.1.14

type EchoServer interface {
	Echo(context.Context, *Bytes) (*Bytes, error)
	// contains filtered or unexported methods
}

EchoServer is the server API for Echo service. All implementations must embed UnimplementedEchoServer for forward compatibility

type ErrorClient

type ErrorClient interface {
	Error(ctx context.Context, in *ErrorRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ErrorClient is the client API for Error 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 NewErrorClient

func NewErrorClient(cc grpc.ClientConnInterface) ErrorClient

type ErrorRequest

type ErrorRequest struct {
	ReturnError bool `protobuf:"varint,1,opt,name=ReturnError,proto3" json:"ReturnError,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorRequest) Descriptor deprecated

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

Deprecated: Use ErrorRequest.ProtoReflect.Descriptor instead.

func (*ErrorRequest) GetReturnError

func (x *ErrorRequest) GetReturnError() bool

func (*ErrorRequest) ProtoMessage

func (*ErrorRequest) ProtoMessage()

func (*ErrorRequest) ProtoReflect

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

func (*ErrorRequest) Reset

func (x *ErrorRequest) Reset()

func (*ErrorRequest) String

func (x *ErrorRequest) String() string

type ErrorServer

type ErrorServer interface {
	Error(context.Context, *ErrorRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ErrorServer is the server API for Error service. All implementations must embed UnimplementedErrorServer for forward compatibility

type HashClient

type HashClient interface {
	Hash(ctx context.Context, in *String, opts ...grpc.CallOption) (*String, error)
}

HashClient is the client API for Hash 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 NewHashClient

func NewHashClient(cc grpc.ClientConnInterface) HashClient

type HashServer

type HashServer interface {
	Hash(context.Context, *String) (*String, error)
	// contains filtered or unexported methods
}

HashServer is the server API for Hash service. All implementations must embed UnimplementedHashServer for forward compatibility

type IncrementClient

type IncrementClient interface {
	Inc(ctx context.Context, in *Number, opts ...grpc.CallOption) (*Number, error)
}

IncrementClient is the client API for Increment 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 NewIncrementClient

func NewIncrementClient(cc grpc.ClientConnInterface) IncrementClient

type IncrementServer

type IncrementServer interface {
	Inc(context.Context, *Number) (*Number, error)
	// contains filtered or unexported methods
}

IncrementServer is the server API for Increment service. All implementations must embed UnimplementedIncrementServer for forward compatibility

type MultiplyClient added in v1.1.14

type MultiplyClient interface {
	Mul(ctx context.Context, in *Operands, opts ...grpc.CallOption) (*Number, error)
}

MultiplyClient is the client API for Multiply 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 NewMultiplyClient added in v1.1.14

func NewMultiplyClient(cc grpc.ClientConnInterface) MultiplyClient

type MultiplyServer added in v1.1.14

type MultiplyServer interface {
	Mul(context.Context, *Operands) (*Number, error)
	// contains filtered or unexported methods
}

MultiplyServer is the server API for Multiply service. All implementations must embed UnimplementedMultiplyServer for forward compatibility

type NotifyClient added in v1.1.14

type NotifyClient interface {
	Notify(ctx context.Context, in *String, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

NotifyClient is the client API for Notify 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 NewNotifyClient added in v1.1.14

func NewNotifyClient(cc grpc.ClientConnInterface) NotifyClient

type NotifyServer added in v1.1.14

type NotifyServer interface {
	Notify(context.Context, *String) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

NotifyServer is the server API for Notify service. All implementations must embed UnimplementedNotifyServer for forward compatibility

type Number

type Number struct {
	Value int64 `protobuf:"varint,1,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*Number) Descriptor deprecated

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

Deprecated: Use Number.ProtoReflect.Descriptor instead.

func (*Number) GetValue

func (x *Number) GetValue() int64

func (*Number) ProtoMessage

func (*Number) ProtoMessage()

func (*Number) ProtoReflect

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

func (*Number) Reset

func (x *Number) Reset()

func (*Number) String

func (x *Number) String() string

type Operands

type Operands struct {
	A int32 `protobuf:"varint,1,opt,name=A,proto3" json:"A,omitempty"`
	B int32 `protobuf:"varint,2,opt,name=B,proto3" json:"B,omitempty"`
	// contains filtered or unexported fields
}

func (*Operands) Descriptor deprecated

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

Deprecated: Use Operands.ProtoReflect.Descriptor instead.

func (*Operands) GetA

func (x *Operands) GetA() int32

func (*Operands) GetB

func (x *Operands) GetB() int32

func (*Operands) ProtoMessage

func (*Operands) ProtoMessage()

func (*Operands) ProtoReflect

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

func (*Operands) Reset

func (x *Operands) Reset()

func (*Operands) String

func (x *Operands) String() string

type SleepClient added in v1.1.14

type SleepClient interface {
	Sleep(ctx context.Context, in *SleepRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SleepClient is the client API for Sleep 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 NewSleepClient added in v1.1.14

func NewSleepClient(cc grpc.ClientConnInterface) SleepClient

type SleepRequest added in v1.1.14

type SleepRequest struct {
	Duration *durationpb.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"`
	Filter   string               `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*SleepRequest) Descriptor deprecated added in v1.1.14

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

Deprecated: Use SleepRequest.ProtoReflect.Descriptor instead.

func (*SleepRequest) GetDuration added in v1.1.14

func (x *SleepRequest) GetDuration() *durationpb.Duration

func (*SleepRequest) GetFilter added in v1.1.14

func (x *SleepRequest) GetFilter() string

func (*SleepRequest) ProtoMessage added in v1.1.14

func (*SleepRequest) ProtoMessage()

func (*SleepRequest) ProtoReflect added in v1.1.14

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

func (*SleepRequest) Reset added in v1.1.14

func (x *SleepRequest) Reset()

func (*SleepRequest) String added in v1.1.14

func (x *SleepRequest) String() string

type SleepServer added in v1.1.14

type SleepServer interface {
	Sleep(context.Context, *SleepRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

SleepServer is the server API for Sleep service. All implementations must embed UnimplementedSleepServer for forward compatibility

type String

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

func (*String) Descriptor deprecated

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

Deprecated: Use String.ProtoReflect.Descriptor instead.

func (*String) GetStr

func (x *String) GetStr() string

func (*String) ProtoMessage

func (*String) ProtoMessage()

func (*String) ProtoReflect

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

func (*String) Reset

func (x *String) Reset()

func (*String) String

func (x *String) String() string

type TestClient

type TestClient interface {
	TestStream(ctx context.Context, opts ...grpc.CallOption) (Test_TestStreamClient, error)
}

TestClient is the client API for Test 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 NewTestClient

func NewTestClient(cc grpc.ClientConnInterface) TestClient

type TestServer

type TestServer interface {
	TestStream(Test_TestStreamServer) error
	// contains filtered or unexported methods
}

TestServer is the server API for Test service. All implementations must embed UnimplementedTestServer for forward compatibility

type Test_TestStreamClient

type Test_TestStreamClient interface {
	Send(*totem.RPC) error
	Recv() (*totem.RPC, error)
	grpc.ClientStream
}

type Test_TestStreamServer

type Test_TestStreamServer interface {
	Send(*totem.RPC) error
	Recv() (*totem.RPC, error)
	grpc.ServerStream
}

type UnimplementedDecrementServer

type UnimplementedDecrementServer struct {
}

UnimplementedDecrementServer must be embedded to have forward compatible implementations.

func (UnimplementedDecrementServer) Dec

type UnimplementedEchoServer added in v1.1.14

type UnimplementedEchoServer struct {
}

UnimplementedEchoServer must be embedded to have forward compatible implementations.

func (UnimplementedEchoServer) Echo added in v1.1.14

type UnimplementedErrorServer

type UnimplementedErrorServer struct {
}

UnimplementedErrorServer must be embedded to have forward compatible implementations.

func (UnimplementedErrorServer) Error

type UnimplementedHashServer

type UnimplementedHashServer struct {
}

UnimplementedHashServer must be embedded to have forward compatible implementations.

func (UnimplementedHashServer) Hash

type UnimplementedIncrementServer

type UnimplementedIncrementServer struct {
}

UnimplementedIncrementServer must be embedded to have forward compatible implementations.

func (UnimplementedIncrementServer) Inc

type UnimplementedMultiplyServer added in v1.1.14

type UnimplementedMultiplyServer struct {
}

UnimplementedMultiplyServer must be embedded to have forward compatible implementations.

func (UnimplementedMultiplyServer) Mul added in v1.1.14

type UnimplementedNotifyServer added in v1.1.14

type UnimplementedNotifyServer struct {
}

UnimplementedNotifyServer must be embedded to have forward compatible implementations.

func (UnimplementedNotifyServer) Notify added in v1.1.14

type UnimplementedSleepServer added in v1.1.14

type UnimplementedSleepServer struct {
}

UnimplementedSleepServer must be embedded to have forward compatible implementations.

func (UnimplementedSleepServer) Sleep added in v1.1.14

type UnimplementedTestServer

type UnimplementedTestServer struct {
}

UnimplementedTestServer must be embedded to have forward compatible implementations.

func (UnimplementedTestServer) TestStream

type UnsafeDecrementServer

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

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

type UnsafeEchoServer added in v1.1.14

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

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

type UnsafeErrorServer

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

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

type UnsafeHashServer

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

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

type UnsafeIncrementServer

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

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

type UnsafeMultiplyServer added in v1.1.14

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

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

type UnsafeNotifyServer added in v1.1.14

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

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

type UnsafeSleepServer added in v1.1.14

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

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

type UnsafeTestServer

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

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

Jump to

Keyboard shortcuts

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