package echoserver

import "github.com/tmc/grpc-websocket-proxy/_examples/cmd/wsechoserver/echoserver"

Package echoserver is a generated protocol buffer package.

It is generated from these files:

echoserver.proto

It has these top-level messages:

EchoRequest
EchoResponse
Heartbeat
Empty

Package echoserver is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index ¶

• Variables
• func RegisterEchoServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
• func RegisterEchoServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
• func RegisterEchoServiceServer(s *grpc.Server, srv EchoServiceServer)
• type EchoRequest
• func (*EchoRequest) Descriptor() ([]byte, []int)
• func (m *EchoRequest) GetMessage() string
• func (*EchoRequest) ProtoMessage()
• func (m *EchoRequest) Reset()
• func (m *EchoRequest) String() string
• type EchoResponse
• func (*EchoResponse) Descriptor() ([]byte, []int)
• func (m *EchoResponse) GetMessage() string
• func (*EchoResponse) ProtoMessage()
• func (m *EchoResponse) Reset()
• func (m *EchoResponse) String() string
• type EchoServiceClient
• func NewEchoServiceClient(cc *grpc.ClientConn) EchoServiceClient
• type EchoServiceServer
• type EchoService_EchoClient
• type EchoService_EchoServer
• type EchoService_HeartbeatsClient
• type EchoService_HeartbeatsServer
• type EchoService_StreamClient
• type EchoService_StreamServer
• type Empty
• func (*Empty) Descriptor() ([]byte, []int)
• func (*Empty) ProtoMessage()
• func (m *Empty) Reset()
• func (m *Empty) String() string
• type Heartbeat
• func (*Heartbeat) Descriptor() ([]byte, []int)
• func (m *Heartbeat) GetStatus() Heartbeat_Status
• func (*Heartbeat) ProtoMessage()
• func (m *Heartbeat) Reset()
• func (m *Heartbeat) String() string
• type Heartbeat_Status
• func (Heartbeat_Status) EnumDescriptor() ([]byte, []int)
• func (x Heartbeat_Status) String() string

Variables ¶

var Heartbeat_Status_name = map[int32]string{
	0: "UNKNOWN",
	1: "OK",
}

var Heartbeat_Status_value = map[string]int32{
	"UNKNOWN": 0,
	"OK":      1,
}

Functions ¶

func RegisterEchoServiceHandler ¶

func RegisterEchoServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterEchoServiceHandler registers the http handlers for service EchoService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterEchoServiceHandlerFromEndpoint ¶

func RegisterEchoServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterEchoServiceHandlerFromEndpoint is same as RegisterEchoServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterEchoServiceServer ¶

func RegisterEchoServiceServer(s *grpc.Server, srv EchoServiceServer)

Types ¶

type EchoRequest ¶

type EchoRequest struct {
	Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
}

func (*EchoRequest) Descriptor ¶

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

func (*EchoRequest) GetMessage ¶

func (m *EchoRequest) GetMessage() string

func (*EchoRequest) ProtoMessage ¶

func (*EchoRequest) ProtoMessage()

func (*EchoRequest) Reset ¶

func (m *EchoRequest) Reset()

func (*EchoRequest) String ¶

func (m *EchoRequest) String() string

type EchoResponse ¶

type EchoResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
}

func (*EchoResponse) Descriptor ¶

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

func (*EchoResponse) GetMessage ¶

func (m *EchoResponse) GetMessage() string

func (*EchoResponse) ProtoMessage ¶

func (*EchoResponse) ProtoMessage()

func (*EchoResponse) Reset ¶

func (m *EchoResponse) Reset()

func (*EchoResponse) String ¶

func (m *EchoResponse) String() string

type EchoServiceClient ¶

type EchoServiceClient interface {
	Echo(ctx context.Context, opts ...grpc.CallOption) (EchoService_EchoClient, error)
	Stream(ctx context.Context, in *Empty, opts ...grpc.CallOption) (EchoService_StreamClient, error)
	Heartbeats(ctx context.Context, opts ...grpc.CallOption) (EchoService_HeartbeatsClient, error)
}

func NewEchoServiceClient ¶

func NewEchoServiceClient(cc *grpc.ClientConn) EchoServiceClient

type EchoServiceServer ¶

type EchoServiceServer interface {
	Echo(EchoService_EchoServer) error
	Stream(*Empty, EchoService_StreamServer) error
	Heartbeats(EchoService_HeartbeatsServer) error
}

type EchoService_EchoClient ¶

type EchoService_EchoClient interface {
	Send(*EchoRequest) error
	Recv() (*EchoResponse, error)
	grpc.ClientStream
}

type EchoService_EchoServer ¶

type EchoService_EchoServer interface {
	Send(*EchoResponse) error
	Recv() (*EchoRequest, error)
	grpc.ServerStream
}

type EchoService_HeartbeatsClient ¶

type EchoService_HeartbeatsClient interface {
	Send(*Empty) error
	Recv() (*Heartbeat, error)
	grpc.ClientStream
}

type EchoService_HeartbeatsServer ¶

type EchoService_HeartbeatsServer interface {
	Send(*Heartbeat) error
	Recv() (*Empty, error)
	grpc.ServerStream
}

type EchoService_StreamClient ¶

type EchoService_StreamClient interface {
	Recv() (*EchoResponse, error)
	grpc.ClientStream
}

type EchoService_StreamServer ¶

type EchoService_StreamServer interface {
	Send(*EchoResponse) error
	grpc.ServerStream
}

type Empty ¶

type Empty struct {
}

func (*Empty) Descriptor ¶

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

func (*Empty) ProtoMessage ¶

func (*Empty) ProtoMessage()

func (*Empty) Reset ¶

func (m *Empty) Reset()

func (*Empty) String ¶

func (m *Empty) String() string

type Heartbeat ¶

type Heartbeat struct {
	Status Heartbeat_Status `protobuf:"varint,1,opt,name=status,enum=echoserver.Heartbeat_Status" json:"status,omitempty"`
}

func (*Heartbeat) Descriptor ¶

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

func (*Heartbeat) GetStatus ¶

func (m *Heartbeat) GetStatus() Heartbeat_Status

func (*Heartbeat) ProtoMessage ¶

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) Reset ¶

func (m *Heartbeat) Reset()

func (*Heartbeat) String ¶

func (m *Heartbeat) String() string

type Heartbeat_Status ¶

type Heartbeat_Status int32

const (
	Heartbeat_UNKNOWN Heartbeat_Status = 0
	Heartbeat_OK      Heartbeat_Status = 1
)

func (Heartbeat_Status) EnumDescriptor ¶

func (Heartbeat_Status) EnumDescriptor() ([]byte, []int)

func (Heartbeat_Status) String ¶

func (x Heartbeat_Status) String() string

Source Files ¶

echoserver.pb.go echoserver.pb.gw.go gen.go