pingpong

package
v0.0.0-...-aece62e Latest Latest
Warning

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

 Go to latest Published: Nov 22, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int

Functions

func NewTChanPingPongInheritedClient 

func NewTChanPingPongInheritedClient(thriftService string, client thrift.TChanClient) *tchanPingPongClient

func NewTChanPingPongServer 

func NewTChanPingPongServer(handler TChanPingPong) thrift.TChanServer

NewTChanPingPongServer wraps a handler for TChanPingPong so it can be registered with a thrift.Server.

Types

type MockTChanPingPong 

type MockTChanPingPong struct {
	mock.Mock
}

func (*MockTChanPingPong) Ping 

func (_m *MockTChanPingPong) Ping(ctx thrift.Context, request *Ping) (*Pong, error)

Ping provides a mock function with given fields: ctx, request

type Ping 

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

Attributes:

  • Key
var PingPongPingArgs_Request_DEFAULT *Ping

func NewPing 

func NewPing() *Ping

func (*Ping) Equals 

func (p *Ping) Equals(other *Ping) bool

func (*Ping) GetKey 

func (p *Ping) GetKey() string

func (*Ping) Read 

func (p *Ping) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Ping) ReadField1 

func (p *Ping) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Ping) String 

func (p *Ping) String() string

func (*Ping) Write 

func (p *Ping) Write(ctx context.Context, oprot thrift.TProtocol) error

type PingError 

type PingError struct {
}
var PingPongPingResult_PingError_DEFAULT *PingError

func NewPingError 

func NewPingError() *PingError

func (*PingError) Equals 

func (p *PingError) Equals(other *PingError) bool

func (*PingError) Error 

func (p *PingError) Error() string

func (*PingError) Read 

func (p *PingError) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*PingError) String 

func (p *PingError) String() string

func (PingError) TExceptionType 

func (PingError) TExceptionType() thrift.TExceptionType

func (*PingError) Write 

func (p *PingError) Write(ctx context.Context, oprot thrift.TProtocol) error

type PingPong 

type PingPong interface {
	// Parameters:
	//  - Request
	Ping(ctx context.Context, request *Ping) (_r *Pong, _err error)
}

type PingPongClient 

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

func NewPingPongClient 

func NewPingPongClient(c thrift.TClient) *PingPongClient

func NewPingPongClientFactory 

func NewPingPongClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *PingPongClient

func NewPingPongClientProtocol 

func NewPingPongClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *PingPongClient

func (*PingPongClient) Client_ 

func (p *PingPongClient) Client_() thrift.TClient

func (*PingPongClient) LastResponseMeta_ 

func (p *PingPongClient) LastResponseMeta_() thrift.ResponseMeta

func (*PingPongClient) Ping 

func (p *PingPongClient) Ping(ctx context.Context, request *Ping) (_r *Pong, _err error)

Parameters:

  • Request

func (*PingPongClient) SetLastResponseMeta_ 

func (p *PingPongClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

type PingPongPingArgs 

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

Attributes:

  • Request

func NewPingPongPingArgs 

func NewPingPongPingArgs() *PingPongPingArgs

func (*PingPongPingArgs) GetRequest 

func (p *PingPongPingArgs) GetRequest() *Ping

func (*PingPongPingArgs) IsSetRequest 

func (p *PingPongPingArgs) IsSetRequest() bool

func (*PingPongPingArgs) Read 

func (p *PingPongPingArgs) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*PingPongPingArgs) ReadField1 

func (p *PingPongPingArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*PingPongPingArgs) String 

func (p *PingPongPingArgs) String() string

func (*PingPongPingArgs) Write 

func (p *PingPongPingArgs) Write(ctx context.Context, oprot thrift.TProtocol) error

type PingPongPingResult 

type PingPongPingResult struct {
	Success   *Pong      `thrift:"success,0" db:"success" json:"success,omitempty"`
	PingError *PingError `thrift:"pingError,1" db:"pingError" json:"pingError,omitempty"`
}

Attributes:

  • Success
  • PingError

func NewPingPongPingResult 

func NewPingPongPingResult() *PingPongPingResult

func (*PingPongPingResult) GetPingError 

func (p *PingPongPingResult) GetPingError() *PingError

func (*PingPongPingResult) GetSuccess 

func (p *PingPongPingResult) GetSuccess() *Pong

func (*PingPongPingResult) IsSetPingError 

func (p *PingPongPingResult) IsSetPingError() bool

func (*PingPongPingResult) IsSetSuccess 

func (p *PingPongPingResult) IsSetSuccess() bool

func (*PingPongPingResult) Read 

func (p *PingPongPingResult) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*PingPongPingResult) ReadField0 

func (p *PingPongPingResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*PingPongPingResult) ReadField1 

func (p *PingPongPingResult) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*PingPongPingResult) String 

func (p *PingPongPingResult) String() string

func (*PingPongPingResult) Write 

func (p *PingPongPingResult) Write(ctx context.Context, oprot thrift.TProtocol) error

type PingPongProcessor 

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

func NewPingPongProcessor 

func NewPingPongProcessor(handler PingPong) *PingPongProcessor

func (*PingPongProcessor) AddToProcessorMap 

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

func (*PingPongProcessor) GetProcessorFunction 

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

func (*PingPongProcessor) Process 

func (p *PingPongProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*PingPongProcessor) ProcessorMap 

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

type Pong 

type Pong struct {
	Source string `thrift:"source,1,required" db:"source" json:"source"`
}

Attributes:

  • Source
var PingPongPingResult_Success_DEFAULT *Pong

func NewPong 

func NewPong() *Pong

func (*Pong) Equals 

func (p *Pong) Equals(other *Pong) bool

func (*Pong) GetSource 

func (p *Pong) GetSource() string

func (*Pong) Read 

func (p *Pong) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*Pong) ReadField1 

func (p *Pong) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*Pong) String 

func (p *Pong) String() string

func (*Pong) Write 

func (p *Pong) Write(ctx context.Context, oprot thrift.TProtocol) error

type TChanPingPong 

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

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

func NewTChanPingPongClient 

func NewTChanPingPongClient(client thrift.TChanClient) TChanPingPong

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

Source Files

View all Source files

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.