module

Documentation

Index

• Variables
• type Foo
  • func NewFoo() *Foo
  • func (x *Foo) GetMyInt() int64
  • func (x *Foo) Read(p thrift.Protocol) error
  • func (x *Foo) SetMyInt(value int64) *Foo
  • func (x *Foo) Write(p thrift.Protocol) error
• type FooBuilder
  • func NewFooBuilder() *FooBuilder
  • func (x *FooBuilder) Emit() *Foo
  • func (x *FooBuilder) MyInt(value int64) *FooBuilder
• type TestService
• type TestServiceChannelClient
  • func NewTestServiceChannelClient(channel thrift.RequestChannel) *TestServiceChannelClient
  • func (c *TestServiceChannelClient) Close() error
  • func (c *TestServiceChannelClient) Init(ctx context.Context, int1 int64) (int64, error)
  • func (c *TestServiceChannelClient) IsOpen() bool
  • func (c *TestServiceChannelClient) Open() error
• type TestServiceClient
  • func NewTestServiceClient(t thrift.Transport, iprot thrift.Protocol, oprot thrift.Protocol) *TestServiceClient
  • func NewTestServiceClientFactory(t thrift.Transport, pf thrift.ProtocolFactory) *TestServiceClient
  • func NewTestServiceClientProtocol(prot thrift.Protocol) *TestServiceClient
  • func NewTestServiceThreadsafeClientProtocol(prot thrift.Protocol) *TestServiceClient
  • func (c *TestServiceClient) Close() error
  • func (c *TestServiceClient) Init(int1 int64) (int64, error)
  • func (c *TestServiceClient) IsOpen() bool
  • func (c *TestServiceClient) Open() error
• type TestServiceClientInterface
• type TestServiceProcessor
  • func NewTestServiceProcessor(handler TestService) *TestServiceProcessor
  • func (p *TestServiceProcessor) AddToFunctionServiceMap(key, service string)
  • func (p *TestServiceProcessor) AddToProcessorMap(key string, processor thrift.ProcessorFunction)
  • func (p *TestServiceProcessor) FunctionServiceMap() map[string]string
  • func (p *TestServiceProcessor) GetProcessorFunction(key string) (processor thrift.ProcessorFunction, err error)
  • func (p *TestServiceProcessor) ProcessorMap() map[string]thrift.ProcessorFunction
• type TestServiceThreadsafeClient
  • func NewTestServiceThreadsafeClient(t thrift.Transport, iprot thrift.Protocol, oprot thrift.Protocol) *TestServiceThreadsafeClient
  • func NewTestServiceThreadsafeClientFactory(t thrift.Transport, pf thrift.ProtocolFactory) *TestServiceThreadsafeClient

Variables

var GoUnusedProtection__ int

Types

type Foo

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

func NewFoo

func NewFoo() *Foo

func (*Foo) GetMyInt

func (x *Foo) GetMyInt() int64

func (*Foo) Read

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

func (*Foo) SetMyInt

func (x *Foo) SetMyInt(value int64) *Foo

func (*Foo) Write

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

type FooBuilder

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

Deprecated: Use Foo.Set* methods instead or set the fields directly.

func NewFooBuilder

func NewFooBuilder() *FooBuilder

func (*FooBuilder) Emit

func (x *FooBuilder) Emit() *Foo

func (*FooBuilder) MyInt

func (x *FooBuilder) MyInt(value int64) *FooBuilder

type TestService

type TestService interface {
	Init(ctx context.Context, int1 int64) (int64, error)
}

type TestServiceChannelClient

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

func NewTestServiceChannelClient

func NewTestServiceChannelClient(channel thrift.RequestChannel) *TestServiceChannelClient

func (*TestServiceChannelClient) Close

func (c *TestServiceChannelClient) Close() error

func (*TestServiceChannelClient) Init

func (c *TestServiceChannelClient) Init(ctx context.Context, int1 int64) (int64, error)

func (*TestServiceChannelClient) IsOpen

func (c *TestServiceChannelClient) IsOpen() bool

func (*TestServiceChannelClient) Open

func (c *TestServiceChannelClient) Open() error

type TestServiceClient

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

Deprecated: Use TestServiceChannelClient instead.

func NewTestServiceClient

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

Deprecated: Use NewTestServiceChannelClient() instead.

func NewTestServiceClientFactory

func NewTestServiceClientFactory(t thrift.Transport, pf thrift.ProtocolFactory) *TestServiceClient

Deprecated: Use NewTestServiceChannelClient() instead.

func NewTestServiceClientProtocol

func NewTestServiceClientProtocol(prot thrift.Protocol) *TestServiceClient

Deprecated: Use NewTestServiceChannelClient() instead.

func NewTestServiceThreadsafeClientProtocol

func NewTestServiceThreadsafeClientProtocol(prot thrift.Protocol) *TestServiceClient

Deprecated: Use NewTestServiceChannelClient() instead.

func (*TestServiceClient) Close

func (c *TestServiceClient) Close() error

func (*TestServiceClient) Init

func (c *TestServiceClient) Init(int1 int64) (int64, error)

func (*TestServiceClient) IsOpen

func (c *TestServiceClient) IsOpen() bool

func (*TestServiceClient) Open

func (c *TestServiceClient) Open() error

type TestServiceClientInterface

type TestServiceClientInterface interface {
	thrift.ClientInterface
	Init(int1 int64) (int64, error)
}

Deprecated: Use TestService instead.

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 = TestServiceClient

Deprecated: Use TestServiceChannelClient instead.

func NewTestServiceThreadsafeClient

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

Deprecated: Use NewTestServiceChannelClient() instead.

func NewTestServiceThreadsafeClientFactory

func NewTestServiceThreadsafeClientFactory(t thrift.Transport, pf thrift.ProtocolFactory) *TestServiceThreadsafeClient

Deprecated: Use NewTestServiceChannelClient() instead.