thrift

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int

Functions

This section is empty.

Types

type GetRequest 

type GetRequest struct {
	Group string `thrift:"group,1" db:"group" json:"group"`
	Key   string `thrift:"key,2" db:"key" json:"key"`
}

Attributes:

  • Group
  • Key
var MemoGetArgs_Req_DEFAULT *GetRequest

func NewGetRequest 

func NewGetRequest() *GetRequest

func (*GetRequest) Equals 

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

func (*GetRequest) GetGroup 

func (p *GetRequest) GetGroup() string

func (*GetRequest) GetKey 

func (p *GetRequest) GetKey() string

func (*GetRequest) Read 

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

func (*GetRequest) ReadField1 

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

func (*GetRequest) ReadField2 

func (p *GetRequest) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*GetRequest) String 

func (p *GetRequest) String() string

func (*GetRequest) Write 

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

type GetResponse 

type GetResponse struct {
	Value []byte `thrift:"value,1" db:"value" json:"value"`
}

Attributes:

  • Value
var MemoGetResult_Success_DEFAULT *GetResponse

func NewGetResponse 

func NewGetResponse() *GetResponse

func (*GetResponse) Equals 

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

func (*GetResponse) GetValue 

func (p *GetResponse) GetValue() []byte

func (*GetResponse) Read 

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

func (*GetResponse) ReadField1 

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

func (*GetResponse) String 

func (p *GetResponse) String() string

func (*GetResponse) Write 

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

type Memo 

type Memo interface {
	// Parameters:
	//  - Req
	Get(ctx context.Context, req *GetRequest) (_r *GetResponse, _err error)
}

type MemoClient 

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

func NewMemoClient 

func NewMemoClient(c thrift.TClient) *MemoClient

func NewMemoClientFactory 

func NewMemoClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *MemoClient

func NewMemoClientProtocol 

func NewMemoClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *MemoClient

func (*MemoClient) Client_ 

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

func (*MemoClient) Get 

func (p *MemoClient) Get(ctx context.Context, req *GetRequest) (_r *GetResponse, _err error)

Parameters:

  • Req

func (*MemoClient) LastResponseMeta_ 

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

func (*MemoClient) SetLastResponseMeta_ 

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

type MemoGetArgs 

type MemoGetArgs struct {
	Req *GetRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewMemoGetArgs 

func NewMemoGetArgs() *MemoGetArgs

func (*MemoGetArgs) GetReq 

func (p *MemoGetArgs) GetReq() *GetRequest

func (*MemoGetArgs) IsSetReq 

func (p *MemoGetArgs) IsSetReq() bool

func (*MemoGetArgs) Read 

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

func (*MemoGetArgs) ReadField1 

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

func (*MemoGetArgs) String 

func (p *MemoGetArgs) String() string

func (*MemoGetArgs) Write 

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

type MemoGetResult 

type MemoGetResult struct {
	Success *GetResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewMemoGetResult 

func NewMemoGetResult() *MemoGetResult

func (*MemoGetResult) GetSuccess 

func (p *MemoGetResult) GetSuccess() *GetResponse

func (*MemoGetResult) IsSetSuccess 

func (p *MemoGetResult) IsSetSuccess() bool

func (*MemoGetResult) Read 

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

func (*MemoGetResult) ReadField0 

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

func (*MemoGetResult) String 

func (p *MemoGetResult) String() string

func (*MemoGetResult) Write 

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

type MemoProcessor 

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

func NewMemoProcessor 

func NewMemoProcessor(handler Memo) *MemoProcessor

func (*MemoProcessor) AddToProcessorMap 

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

func (*MemoProcessor) GetProcessorFunction 

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

func (*MemoProcessor) Process 

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

func (*MemoProcessor) ProcessorMap 

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

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.