ping

Documentation

Overview

Package ping is generated code used to make or handle TChannel calls using Thrift.

Index

• Variables
• func NewTChanPingPongServiceInheritedClient(thriftService string, client thrift.TChanClient) *tchanPingPongServiceClient
• func NewTChanPingPongServiceServer(handler TChanPingPongService) thrift.TChanServer
• type Ping
  • func NewPing() *Ping
  • func (p *Ping) GetKey() string
  • func (p *Ping) Read(iprot thrift.TProtocol) error
  • func (p *Ping) String() string
  • func (p *Ping) Write(oprot thrift.TProtocol) error
• type PingPongService
• type PingPongServiceClient
  • func NewPingPongServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *PingPongServiceClient
  • func NewPingPongServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *PingPongServiceClient
  • func (p *PingPongServiceClient) Ping(request *Ping) (r *Pong, err error)
• type PingPongServicePingArgs
  • func NewPingPongServicePingArgs() *PingPongServicePingArgs
  • func (p *PingPongServicePingArgs) GetRequest() *Ping
  • func (p *PingPongServicePingArgs) IsSetRequest() bool
  • func (p *PingPongServicePingArgs) Read(iprot thrift.TProtocol) error
  • func (p *PingPongServicePingArgs) String() string
  • func (p *PingPongServicePingArgs) Write(oprot thrift.TProtocol) error
• type PingPongServicePingResult
  • func NewPingPongServicePingResult() *PingPongServicePingResult
  • func (p *PingPongServicePingResult) GetSuccess() *Pong
  • func (p *PingPongServicePingResult) IsSetSuccess() bool
  • func (p *PingPongServicePingResult) Read(iprot thrift.TProtocol) error
  • func (p *PingPongServicePingResult) String() string
  • func (p *PingPongServicePingResult) Write(oprot thrift.TProtocol) error
• type PingPongServiceProcessor
  • func NewPingPongServiceProcessor(handler PingPongService) *PingPongServiceProcessor
  • func (p *PingPongServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
  • func (p *PingPongServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
  • func (p *PingPongServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
  • func (p *PingPongServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
• type Pong
  • func NewPong() *Pong
  • func (p *Pong) GetFrom_() string
  • func (p *Pong) GetMessage() string
  • func (p *Pong) GetPheader() string
  • func (p *Pong) IsSetPheader() bool
  • func (p *Pong) Read(iprot thrift.TProtocol) error
  • func (p *Pong) String() string
  • func (p *Pong) Write(oprot thrift.TProtocol) error
• type TChanPingPongService
  • func NewTChanPingPongServiceClient(client thrift.TChanClient) TChanPingPongService

Variables

var GoUnusedProtection__ int

var Pong_Pheader_DEFAULT string

Functions

func NewTChanPingPongServiceInheritedClient

func NewTChanPingPongServiceInheritedClient(thriftService string, client thrift.TChanClient) *tchanPingPongServiceClient

func NewTChanPingPongServiceServer

func NewTChanPingPongServiceServer(handler TChanPingPongService) thrift.TChanServer

NewTChanPingPongServiceServer wraps a handler for TChanPingPongService so it can be registered with a thrift.Server.

Types

type Ping

type Ping struct {
	Key string `thrift:"key,1,required" json:"key"`
}

Attributes:

• Key

var PingPongServicePingArgs_Request_DEFAULT *Ping

func NewPing

func NewPing() *Ping

func (*Ping) GetKey

func (p *Ping) GetKey() string

func (*Ping) Read

func (p *Ping) Read(iprot thrift.TProtocol) error

func (*Ping) String

func (p *Ping) String() string

func (*Ping) Write

func (p *Ping) Write(oprot thrift.TProtocol) error

type PingPongService

type PingPongService interface {
	// Parameters:
	//  - Request
	Ping(request *Ping) (r *Pong, err error)
}

type PingPongServiceClient

type PingPongServiceClient struct {
	Transport       thrift.TTransport
	ProtocolFactory thrift.TProtocolFactory
	InputProtocol   thrift.TProtocol
	OutputProtocol  thrift.TProtocol
	SeqId           int32
}

func NewPingPongServiceClientFactory

func NewPingPongServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *PingPongServiceClient

func NewPingPongServiceClientProtocol

func NewPingPongServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *PingPongServiceClient

func (*PingPongServiceClient) Ping

func (p *PingPongServiceClient) Ping(request *Ping) (r *Pong, err error)

Parameters:

• Request

type PingPongServicePingArgs

type PingPongServicePingArgs struct {
	Request *Ping `thrift:"request,1" json:"request"`
}

Attributes:

• Request

func NewPingPongServicePingArgs

func NewPingPongServicePingArgs() *PingPongServicePingArgs

func (*PingPongServicePingArgs) GetRequest

func (p *PingPongServicePingArgs) GetRequest() *Ping

func (*PingPongServicePingArgs) IsSetRequest

func (p *PingPongServicePingArgs) IsSetRequest() bool

func (*PingPongServicePingArgs) Read

func (p *PingPongServicePingArgs) Read(iprot thrift.TProtocol) error

func (*PingPongServicePingArgs) String

func (p *PingPongServicePingArgs) String() string

func (*PingPongServicePingArgs) Write

func (p *PingPongServicePingArgs) Write(oprot thrift.TProtocol) error

type PingPongServicePingResult

type PingPongServicePingResult struct {
	Success *Pong `thrift:"success,0" json:"success,omitempty"`
}

Attributes:

• Success

func NewPingPongServicePingResult

func NewPingPongServicePingResult() *PingPongServicePingResult

func (*PingPongServicePingResult) GetSuccess

func (p *PingPongServicePingResult) GetSuccess() *Pong

func (*PingPongServicePingResult) IsSetSuccess

func (p *PingPongServicePingResult) IsSetSuccess() bool

func (*PingPongServicePingResult) Read

func (p *PingPongServicePingResult) Read(iprot thrift.TProtocol) error

func (*PingPongServicePingResult) String

func (p *PingPongServicePingResult) String() string

func (*PingPongServicePingResult) Write

func (p *PingPongServicePingResult) Write(oprot thrift.TProtocol) error

type PingPongServiceProcessor

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

func NewPingPongServiceProcessor

func NewPingPongServiceProcessor(handler PingPongService) *PingPongServiceProcessor

func (*PingPongServiceProcessor) AddToProcessorMap

func (p *PingPongServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*PingPongServiceProcessor) GetProcessorFunction

func (p *PingPongServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*PingPongServiceProcessor) Process

func (p *PingPongServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*PingPongServiceProcessor) ProcessorMap

func (p *PingPongServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type Pong

type Pong struct {
	Message string  `thrift:"message,1,required" json:"message"`
	From_   string  `thrift:"from_,2,required" json:"from_"`
	Pheader *string `thrift:"pheader,3" json:"pheader,omitempty"`
}

Attributes:

• Message
• From_
• Pheader

var PingPongServicePingResult_Success_DEFAULT *Pong

func NewPong

func NewPong() *Pong

func (*Pong) GetFrom_

func (p *Pong) GetFrom_() string

func (*Pong) GetMessage

func (p *Pong) GetMessage() string

func (*Pong) GetPheader

func (p *Pong) GetPheader() string

func (*Pong) IsSetPheader

func (p *Pong) IsSetPheader() bool

func (*Pong) Read

func (p *Pong) Read(iprot thrift.TProtocol) error

func (*Pong) String

func (p *Pong) String() string

func (*Pong) Write

func (p *Pong) Write(oprot thrift.TProtocol) error

type TChanPingPongService

type TChanPingPongService interface {
	Ping(ctx thrift.Context, request *Ping) (*Pong, error)
}

TChanPingPongService is the interface that defines the server handler and client interface.

func NewTChanPingPongServiceClient

func NewTChanPingPongServiceClient(client thrift.TChanClient) TChanPingPongService

NewTChanPingPongServiceClient creates a client that can be used to make remote calls.