module

package
v0.0.0-...-7428086 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source
var GoUnusedProtection__ int
View Source
var TestServiceInitResult_Success_DEFAULT int64

Functions

This section is empty.

Types

type Foo

type Foo struct {
	MyInt int64 `thrift:"MyInt,1" db:"MyInt" json:"MyInt"`
}

Attributes:

  • MyInt

func NewFoo

func NewFoo() *Foo

func (*Foo) GetMyInt

func (p *Foo) GetMyInt() int64

func (*Foo) Read

func (p *Foo) Read(iprot thrift.Protocol) error

func (*Foo) ReadField1

func (p *Foo) ReadField1(iprot thrift.Protocol) error

func (*Foo) SetMyInt

func (f *Foo) SetMyInt(myInt int64) *Foo

func (*Foo) String

func (p *Foo) String() string

func (*Foo) Write

func (p *Foo) Write(oprot thrift.Protocol) error

type FooBuilder

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

func NewFooBuilder

func NewFooBuilder() *FooBuilder

func (FooBuilder) Emit

func (p FooBuilder) Emit() *Foo

func (*FooBuilder) MyInt

func (f *FooBuilder) MyInt(myInt int64) *FooBuilder

type TestService

type TestService interface {
	// Parameters:
	//  - Int1
	Init(int1 int64) (_r int64, err error)
}

type TestServiceChannelClient

type TestServiceChannelClient struct {
	RequestChannel thrift.RequestChannel
}

func NewTestServiceChannelClient

func NewTestServiceChannelClient(channel thrift.RequestChannel) *TestServiceChannelClient

func (*TestServiceChannelClient) Close

func (c *TestServiceChannelClient) Close() error

func (*TestServiceChannelClient) Init

func (p *TestServiceChannelClient) Init(ctx context.Context, int1 int64) (_r int64, err error)

Parameters:

  • Int1

func (*TestServiceChannelClient) IsOpen

func (c *TestServiceChannelClient) IsOpen() bool

func (*TestServiceChannelClient) Open

func (c *TestServiceChannelClient) Open() error

type TestServiceClient

type TestServiceClient struct {
	TestServiceClientInterface
	CC thrift.ClientConn
}

func NewTestServiceClient

func NewTestServiceClient(t thrift.Transport, iprot thrift.Protocol, oprot thrift.Protocol) *TestServiceClient

func NewTestServiceClientProtocol

func NewTestServiceClientProtocol(prot thrift.Protocol) *TestServiceClient

func (*TestServiceClient) Close

func (client *TestServiceClient) Close() error

func (*TestServiceClient) Init

func (p *TestServiceClient) Init(int1 int64) (_r int64, err error)

Parameters:

  • Int1

func (*TestServiceClient) IsOpen

func (client *TestServiceClient) IsOpen() bool

func (*TestServiceClient) Open

func (client *TestServiceClient) Open() error

type TestServiceClientInterface

type TestServiceClientInterface interface {
	thrift.ClientInterface
	// Parameters:
	//  - Int1
	Init(int1 int64) (_r int64, err error)
}

type TestServiceInitArgs

type TestServiceInitArgs struct {
	thrift.IRequest
	Int1 int64 `thrift:"int1,1" db:"int1" json:"int1"`
}

Attributes:

  • Int1

func NewTestServiceInitArgs

func NewTestServiceInitArgs() *TestServiceInitArgs

func (*TestServiceInitArgs) GetInt1

func (p *TestServiceInitArgs) GetInt1() int64

func (*TestServiceInitArgs) Read

func (p *TestServiceInitArgs) Read(iprot thrift.Protocol) error

func (*TestServiceInitArgs) ReadField1

func (p *TestServiceInitArgs) ReadField1(iprot thrift.Protocol) error

func (*TestServiceInitArgs) SetInt1

func (t *TestServiceInitArgs) SetInt1(int1 int64) *TestServiceInitArgs

func (*TestServiceInitArgs) String

func (p *TestServiceInitArgs) String() string

func (*TestServiceInitArgs) Write

func (p *TestServiceInitArgs) Write(oprot thrift.Protocol) error

type TestServiceInitArgsBuilder

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

func NewTestServiceInitArgsBuilder

func NewTestServiceInitArgsBuilder() *TestServiceInitArgsBuilder

func (TestServiceInitArgsBuilder) Emit

func (*TestServiceInitArgsBuilder) Int1

type TestServiceInitResult

type TestServiceInitResult struct {
	thrift.IResponse
	Success *int64 `thrift:"success,0,optional" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewTestServiceInitResult

func NewTestServiceInitResult() *TestServiceInitResult

func (*TestServiceInitResult) Exception

func (*TestServiceInitResult) GetSuccess

func (p *TestServiceInitResult) GetSuccess() int64

func (*TestServiceInitResult) IsSetSuccess

func (p *TestServiceInitResult) IsSetSuccess() bool

func (*TestServiceInitResult) Read

func (p *TestServiceInitResult) Read(iprot thrift.Protocol) error

func (*TestServiceInitResult) ReadField0

func (p *TestServiceInitResult) ReadField0(iprot thrift.Protocol) error

func (*TestServiceInitResult) SetSuccess

func (t *TestServiceInitResult) SetSuccess(success *int64) *TestServiceInitResult

func (*TestServiceInitResult) String

func (p *TestServiceInitResult) String() string

func (*TestServiceInitResult) Write

func (p *TestServiceInitResult) Write(oprot thrift.Protocol) error

type TestServiceInitResultBuilder

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

func NewTestServiceInitResultBuilder

func NewTestServiceInitResultBuilder() *TestServiceInitResultBuilder

func (TestServiceInitResultBuilder) Emit

func (*TestServiceInitResultBuilder) Success

type TestServiceProcessor

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

func NewTestServiceProcessor

func NewTestServiceProcessor(handler TestService) *TestServiceProcessor

func (*TestServiceProcessor) AddToFunctionServiceMap

func (p *TestServiceProcessor) AddToFunctionServiceMap(key, service string)

func (*TestServiceProcessor) AddToProcessorMap

func (p *TestServiceProcessor) AddToProcessorMap(key string, processor thrift.ProcessorFunction)

func (*TestServiceProcessor) FunctionServiceMap

func (p *TestServiceProcessor) FunctionServiceMap() map[string]string

func (*TestServiceProcessor) GetProcessorFunction

func (p *TestServiceProcessor) GetProcessorFunction(key string) (processor thrift.ProcessorFunction, err error)

func (*TestServiceProcessor) ProcessorMap

func (p *TestServiceProcessor) ProcessorMap() map[string]thrift.ProcessorFunction

type TestServiceThreadsafeClient

type TestServiceThreadsafeClient struct {
	TestServiceClientInterface
	CC thrift.ClientConn
	Mu sync.Mutex
}

func NewTestServiceThreadsafeClient

func NewTestServiceThreadsafeClient(t thrift.Transport, iprot thrift.Protocol, oprot thrift.Protocol) *TestServiceThreadsafeClient

func NewTestServiceThreadsafeClientProtocol

func NewTestServiceThreadsafeClientProtocol(prot thrift.Protocol) *TestServiceThreadsafeClient

func (*TestServiceThreadsafeClient) Close

func (client *TestServiceThreadsafeClient) Close() error

func (*TestServiceThreadsafeClient) Init

func (p *TestServiceThreadsafeClient) Init(int1 int64) (_r int64, err error)

Parameters:

  • Int1

func (*TestServiceThreadsafeClient) IsOpen

func (client *TestServiceThreadsafeClient) IsOpen() bool

func (*TestServiceThreadsafeClient) Open

func (client *TestServiceThreadsafeClient) Open() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL