service

type EchoServiceClient ¶

type EchoServiceClient interface {
	Echo(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
}

EchoServiceClient is the client API for EchoService 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 NewEchoServiceClient(cc grpc.ClientConnInterface) EchoServiceClient

type EchoServiceServer ¶

type EchoServiceServer interface {
	Echo(context.Context, *Request) (*Response, error)
}

EchoServiceServer is the server API for EchoService service. All implementations should embed UnimplementedEchoServiceServer for forward compatibility

type GrpcServer ¶

type GrpcServer struct {
	Host string
	Port int
}

GrpcServer gRPC server

func NewGrpcServer(host string, port int) (server *GrpcServer, err error)

func (s *GrpcServer) Start()

type HttpServer ¶

type HttpServer struct {
	Host string
	Port int
}

http server

func NewHttpServer(host string, port int) (server *HttpServer, err error)

func (s *HttpServer) Start()

type Request ¶

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

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

func (x *Request) GetMessage() string

func (*Request) ProtoMessage()

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

func (x *Request) Reset()

func (x *Request) String() string

type Response ¶

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

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

func (x *Response) GetMessage() string

func (*Response) ProtoMessage()

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

func (x *Response) Reset()

func (x *Response) String() string

type TcpServer ¶

type TcpServer struct {
	Host string
	Port int
}

func NewTcpServer(host string, port int) (*TcpServer, error)

func (s *TcpServer) Start()

type UdpServer ¶

type UdpServer struct {
	Host string
	Port int
}

func NewUdpServer(host string, port int) (server *UdpServer, err error)

func (s *UdpServer) Start()

type UnimplementedEchoServiceServer ¶

type UnimplementedEchoServiceServer struct {
}

UnimplementedEchoServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedEchoServiceServer) Echo(context.Context, *Request) (*Response, error)

type UnsafeEchoServiceServer ¶

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

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

type WebSocketServer ¶

type WebSocketServer struct {
	Host string
	Port int
}

websocket server

func NewWebSocketServer(host string, port int) (server *WebSocketServer, err error)

func (s *WebSocketServer) Start() (err error)