pingpong

Documentation

Index

• func RegisterPongerHandler(s server.Server, hdlr PongerHandler, opts ...server.HandlerOption) error
• func RegisterPongerServer(s *grpc.Server, srv PongerServer)
• type PingReply
  • func (*PingReply) Descriptor() ([]byte, []int)
  • func (m *PingReply) GetEnd() *timestamp.Timestamp
  • func (m *PingReply) GetStart() *timestamp.Timestamp
  • func (*PingReply) ProtoMessage()
  • func (m *PingReply) Reset()
  • func (m *PingReply) String() string
  • func (m *PingReply) XXX_DiscardUnknown()
  • func (m *PingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PingReply) XXX_Merge(src proto.Message)
  • func (m *PingReply) XXX_Size() int
  • func (m *PingReply) XXX_Unmarshal(b []byte) error
• type PingRequest
  • func (*PingRequest) Descriptor() ([]byte, []int)
  • func (m *PingRequest) GetStart() *timestamp.Timestamp
  • func (*PingRequest) ProtoMessage()
  • func (m *PingRequest) Reset()
  • func (m *PingRequest) String() string
  • func (m *PingRequest) XXX_DiscardUnknown()
  • func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PingRequest) XXX_Merge(src proto.Message)
  • func (m *PingRequest) XXX_Size() int
  • func (m *PingRequest) XXX_Unmarshal(b []byte) error
• type PongerClient
  • func NewPongerClient(cc *grpc.ClientConn) PongerClient
• type PongerHandler
• type PongerServer
• type PongerService
  • func NewPongerService(name string, c client.Client) PongerService
• type UnimplementedPongerServer
  • func (*UnimplementedPongerServer) Ping(ctx context.Context, req *PingRequest) (*PingReply, error)

Functions

func RegisterPongerHandler

func RegisterPongerHandler(s server.Server, hdlr PongerHandler, opts ...server.HandlerOption) error

func RegisterPongerServer

func RegisterPongerServer(s *grpc.Server, srv PongerServer)

Types

type PingReply

type PingReply struct {
	Start                *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End                  *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*PingReply) Descriptor

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

func (*PingReply) GetEnd

func (m *PingReply) GetEnd() *timestamp.Timestamp

func (*PingReply) GetStart

func (m *PingReply) GetStart() *timestamp.Timestamp

func (*PingReply) ProtoMessage

func (*PingReply) ProtoMessage()

func (*PingReply) Reset

func (m *PingReply) Reset()

func (*PingReply) String

func (m *PingReply) String() string

func (*PingReply) XXX_DiscardUnknown

func (m *PingReply) XXX_DiscardUnknown()

func (*PingReply) XXX_Marshal

func (m *PingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingReply) XXX_Merge

func (m *PingReply) XXX_Merge(src proto.Message)

func (*PingReply) XXX_Size

func (m *PingReply) XXX_Size() int

func (*PingReply) XXX_Unmarshal

func (m *PingReply) XXX_Unmarshal(b []byte) error

type PingRequest

type PingRequest struct {
	Start                *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*PingRequest) Descriptor

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

func (*PingRequest) GetStart

func (m *PingRequest) GetStart() *timestamp.Timestamp

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset

func (m *PingRequest) Reset()

func (*PingRequest) String

func (m *PingRequest) String() string

func (*PingRequest) XXX_DiscardUnknown

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal

func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingRequest) XXX_Merge

func (m *PingRequest) XXX_Merge(src proto.Message)

func (*PingRequest) XXX_Size

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal

func (m *PingRequest) XXX_Unmarshal(b []byte) error

type PongerClient

type PongerClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingReply, error)
}

PongerClient is the client API for Ponger service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPongerClient

func NewPongerClient(cc *grpc.ClientConn) PongerClient

type PongerHandler

type PongerHandler interface {
	Ping(context.Context, *PingRequest, *PingReply) error
}

type PongerServer

type PongerServer interface {
	Ping(context.Context, *PingRequest) (*PingReply, error)
}

PongerServer is the server API for Ponger service.

type PongerService

type PongerService interface {
	Ping(ctx context.Context, in *PingRequest, opts ...client.CallOption) (*PingReply, error)
}

func NewPongerService

func NewPongerService(name string, c client.Client) PongerService

type UnimplementedPongerServer

type UnimplementedPongerServer struct {
}

UnimplementedPongerServer can be embedded to have forward compatible implementations.

func (*UnimplementedPongerServer) Ping

func (*UnimplementedPongerServer) Ping(ctx context.Context, req *PingRequest) (*PingReply, error)