demomod

package module
Version: v0.0.0-...-2c1fc5b Latest Latest
Warning

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

 Go to latest Published: Nov 19, 2022 License: Apache-2.0 Imports: 8 Imported by: 1

README

adapterkit-module-demo

simple adapterkit module demo

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DemomodSvc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "io.moul.adapterkit_module_demo.DemomodSvc",
	HandlerType: (*DemomodSvcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Sum",
			Handler:    _DemomodSvc_Sum_Handler,
		},
		{
			MethodName: "SayHello",
			Handler:    _DemomodSvc_SayHello_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "EchoStream",
			Handler:       _DemomodSvc_EchoStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "demomod.proto",
}

DemomodSvc_ServiceDesc is the grpc.ServiceDesc for DemomodSvc 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_demomod_proto protoreflect.FileDescriptor

Functions

func RegisterDemomodSvcServer 

func RegisterDemomodSvcServer(s grpc.ServiceRegistrar, srv DemomodSvcServer)

Types

type DemomodSvcClient 

type DemomodSvcClient interface {
	Sum(ctx context.Context, in *Sum_Request, opts ...grpc.CallOption) (*Sum_Result, error)
	SayHello(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HelloResult, error)
	EchoStream(ctx context.Context, opts ...grpc.CallOption) (DemomodSvc_EchoStreamClient, error)
}

DemomodSvcClient is the client API for DemomodSvc 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 NewDemomodSvcClient 

func NewDemomodSvcClient(cc grpc.ClientConnInterface) DemomodSvcClient

type DemomodSvcServer 

type DemomodSvcServer interface {
	Sum(context.Context, *Sum_Request) (*Sum_Result, error)
	SayHello(context.Context, *Empty) (*HelloResult, error)
	EchoStream(DemomodSvc_EchoStreamServer) error
	// contains filtered or unexported methods
}

DemomodSvcServer is the server API for DemomodSvc service. All implementations must embed UnimplementedDemomodSvcServer for forward compatibility

func New 

func New(param string) DemomodSvcServer

type DemomodSvc_EchoStreamClient 

type DemomodSvc_EchoStreamClient interface {
	Send(*EchoStream_Input) error
	Recv() (*EchoStream_Output, error)
	grpc.ClientStream
}

type DemomodSvc_EchoStreamServer 

type DemomodSvc_EchoStreamServer interface {
	Send(*EchoStream_Output) error
	Recv() (*EchoStream_Input, error)
	grpc.ServerStream
}

type EchoStream 

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

func (*EchoStream) Descriptor deprecated 

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

Deprecated: Use EchoStream.ProtoReflect.Descriptor instead.

func (*EchoStream) ProtoMessage 

func (*EchoStream) ProtoMessage()

func (*EchoStream) ProtoReflect 

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

func (*EchoStream) Reset 

func (x *EchoStream) Reset()

func (*EchoStream) String 

func (x *EchoStream) String() string

type EchoStream_Input 

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

func (*EchoStream_Input) Descriptor deprecated 

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

Deprecated: Use EchoStream_Input.ProtoReflect.Descriptor instead.

func (*EchoStream_Input) GetText 

func (x *EchoStream_Input) GetText() string

func (*EchoStream_Input) ProtoMessage 

func (*EchoStream_Input) ProtoMessage()

func (*EchoStream_Input) ProtoReflect 

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

func (*EchoStream_Input) Reset 

func (x *EchoStream_Input) Reset()

func (*EchoStream_Input) String 

func (x *EchoStream_Input) String() string

type EchoStream_Output 

type EchoStream_Output struct {
	Reply string `protobuf:"bytes,2,opt,name=reply,proto3" json:"reply,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoStream_Output) Descriptor deprecated 

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

Deprecated: Use EchoStream_Output.ProtoReflect.Descriptor instead.

func (*EchoStream_Output) GetReply 

func (x *EchoStream_Output) GetReply() string

func (*EchoStream_Output) ProtoMessage 

func (*EchoStream_Output) ProtoMessage()

func (*EchoStream_Output) ProtoReflect 

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

func (*EchoStream_Output) Reset 

func (x *EchoStream_Output) Reset()

func (*EchoStream_Output) String 

func (x *EchoStream_Output) String() string

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 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type HelloResult 

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

func (*HelloResult) Descriptor deprecated 

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

Deprecated: Use HelloResult.ProtoReflect.Descriptor instead.

func (*HelloResult) GetMsg 

func (x *HelloResult) GetMsg() string

func (*HelloResult) ProtoMessage 

func (*HelloResult) ProtoMessage()

func (*HelloResult) ProtoReflect 

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

func (*HelloResult) Reset 

func (x *HelloResult) Reset()

func (*HelloResult) String 

func (x *HelloResult) String() string

type Sum 

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

func (*Sum) Descriptor deprecated 

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

Deprecated: Use Sum.ProtoReflect.Descriptor instead.

func (*Sum) ProtoMessage 

func (*Sum) ProtoMessage()

func (*Sum) ProtoReflect 

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

func (*Sum) Reset 

func (x *Sum) Reset()

func (*Sum) String 

func (x *Sum) String() string

type Sum_Request 

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

func (*Sum_Request) Descriptor deprecated 

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

Deprecated: Use Sum_Request.ProtoReflect.Descriptor instead.

func (*Sum_Request) GetA 

func (x *Sum_Request) GetA() int64

func (*Sum_Request) GetB 

func (x *Sum_Request) GetB() int64

func (*Sum_Request) ProtoMessage 

func (*Sum_Request) ProtoMessage()

func (*Sum_Request) ProtoReflect 

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

func (*Sum_Request) Reset 

func (x *Sum_Request) Reset()

func (*Sum_Request) String 

func (x *Sum_Request) String() string

type Sum_Result 

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

func (*Sum_Result) Descriptor deprecated 

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

Deprecated: Use Sum_Result.ProtoReflect.Descriptor instead.

func (*Sum_Result) GetC 

func (x *Sum_Result) GetC() int64

func (*Sum_Result) ProtoMessage 

func (*Sum_Result) ProtoMessage()

func (*Sum_Result) ProtoReflect 

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

func (*Sum_Result) Reset 

func (x *Sum_Result) Reset()

func (*Sum_Result) String 

func (x *Sum_Result) String() string

type UnimplementedDemomodSvcServer 

type UnimplementedDemomodSvcServer struct {
}

UnimplementedDemomodSvcServer must be embedded to have forward compatible implementations.

func (UnimplementedDemomodSvcServer) EchoStream 

func (UnimplementedDemomodSvcServer) EchoStream(DemomodSvc_EchoStreamServer) error

func (UnimplementedDemomodSvcServer) SayHello 

func (UnimplementedDemomodSvcServer) SayHello(context.Context, *Empty) (*HelloResult, error)

func (UnimplementedDemomodSvcServer) Sum 

func (UnimplementedDemomodSvcServer) Sum(context.Context, *Sum_Request) (*Sum_Result, error)

type UnsafeDemomodSvcServer 

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

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

Source Files

View all

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.