flume

package

v0.0.0-...-6222cb7 Latest Latest Go to latest Published: Oct 13, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/melpin/flume-bridge

Documentation ¶

Index ¶

Variables
type AppendArgs
- func NewAppendArgs() *AppendArgs
- func (p *AppendArgs) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *AppendArgs) String() string
- func (p *AppendArgs) Write(ctx context.Context, oprot thrift.TProtocol) error
type AppendBatchArgs
- func NewAppendBatchArgs() *AppendBatchArgs
- func (p *AppendBatchArgs) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *AppendBatchArgs) String() string
- func (p *AppendBatchArgs) Write(ctx context.Context, oprot thrift.TProtocol) error
type AppendBatchResult
- func NewAppendBatchResult() *AppendBatchResult
- func (p *AppendBatchResult) IsSetSuccess() bool
- func (p *AppendBatchResult) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *AppendBatchResult) String() string
- func (p *AppendBatchResult) Write(ctx context.Context, oprot thrift.TProtocol) error
type AppendResult
- func NewAppendResult() *AppendResult
- func (p *AppendResult) IsSetSuccess() bool
- func (p *AppendResult) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *AppendResult) String() string
- func (p *AppendResult) Write(ctx context.Context, oprot thrift.TProtocol) error
type Status
- func StatusFromString(s string) (Status, error)
- func (p Status) String() string
type ThriftFlumeEvent
- func NewThriftFlumeEvent() *ThriftFlumeEvent
- func (p *ThriftFlumeEvent) EventFillUp(headers map[string]string, body []byte)
- func (p *ThriftFlumeEvent) Read(ctx context.Context, iprot thrift.TProtocol) error
- func (p *ThriftFlumeEvent) String() string
- func (p *ThriftFlumeEvent) Write(ctx context.Context, oprot thrift.TProtocol) error
type ThriftSourceProtocol
type ThriftSourceProtocolClient
- func NewThriftSourceProtocolClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ThriftSourceProtocolClient
- func (p *ThriftSourceProtocolClient) Append(ctx context.Context, event *ThriftFlumeEvent) (r Status, err error)
- func (p *ThriftSourceProtocolClient) AppendBatch(ctx context.Context, events []*ThriftFlumeEvent) (r Status, err error)
type ThriftSourceProtocolProcessor
- func (p *ThriftSourceProtocolProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
- func (p *ThriftSourceProtocolProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
- func (p *ThriftSourceProtocolProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err error)
- func (p *ThriftSourceProtocolProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

Constants ¶

This section is empty.

Variables ¶

View Source

var GoUnusedProtection__ int

Functions ¶

This section is empty.

Types ¶

type AppendArgs ¶

type AppendArgs struct {
	Event *ThriftFlumeEvent `thrift:"event,1"`
}

func NewAppendArgs ¶

func NewAppendArgs() *AppendArgs

func (*AppendArgs) Read ¶

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

func (*AppendArgs) String ¶

func (p *AppendArgs) String() string

func (*AppendArgs) Write ¶

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

type AppendBatchArgs ¶

type AppendBatchArgs struct {
	Events []*ThriftFlumeEvent `thrift:"events,1"`
}

func NewAppendBatchArgs ¶

func NewAppendBatchArgs() *AppendBatchArgs

func (*AppendBatchArgs) Read ¶

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

func (*AppendBatchArgs) String ¶

func (p *AppendBatchArgs) String() string

func (*AppendBatchArgs) Write ¶

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

type AppendBatchResult ¶

type AppendBatchResult struct {
	Success Status `thrift:"success,0"`
}

func NewAppendBatchResult ¶

func NewAppendBatchResult() *AppendBatchResult

func (*AppendBatchResult) IsSetSuccess ¶

func (p *AppendBatchResult) IsSetSuccess() bool

func (*AppendBatchResult) Read ¶

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

func (*AppendBatchResult) String ¶

func (p *AppendBatchResult) String() string

func (*AppendBatchResult) Write ¶

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

type AppendResult ¶

type AppendResult struct {
	Success Status `thrift:"success,0"`
}

func NewAppendResult ¶

func NewAppendResult() *AppendResult

func (*AppendResult) IsSetSuccess ¶

func (p *AppendResult) IsSetSuccess() bool

func (*AppendResult) Read ¶

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

func (*AppendResult) String ¶

func (p *AppendResult) String() string

func (*AppendResult) Write ¶

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

type Status ¶

type Status int64

const (
	Status_OK      Status = 0
	Status_FAILED  Status = 1
	Status_ERROR   Status = 2
	Status_UNKNOWN Status = 3
)

func StatusFromString ¶

func StatusFromString(s string) (Status, error)

func (Status) String ¶

func (p Status) String() string

type ThriftFlumeEvent ¶

type ThriftFlumeEvent struct {
	Headers map[string]string `thrift:"headers,1,required"`
	Body    []byte            `thrift:"body,2,required"`
}

func NewThriftFlumeEvent ¶

func NewThriftFlumeEvent() *ThriftFlumeEvent

func (*ThriftFlumeEvent) EventFillUp ¶

func (p *ThriftFlumeEvent) EventFillUp(headers map[string]string, body []byte)

func (*ThriftFlumeEvent) Read ¶

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

func (*ThriftFlumeEvent) String ¶

func (p *ThriftFlumeEvent) String() string

func (*ThriftFlumeEvent) Write ¶

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

type ThriftSourceProtocol ¶

type ThriftSourceProtocol interface {
	// Parameters:
	//  - Event
	Append(event *ThriftFlumeEvent) (r Status, err error)
	// Parameters:
	//  - Events
	AppendBatch(events []*ThriftFlumeEvent) (r Status, err error)
}

type ThriftSourceProtocolClient ¶

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

func NewThriftSourceProtocolClientFactory ¶

func NewThriftSourceProtocolClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ThriftSourceProtocolClient

func (*ThriftSourceProtocolClient) Append ¶

func (p *ThriftSourceProtocolClient) Append(ctx context.Context, event *ThriftFlumeEvent) (r Status, err error)

Parameters:

Event

func (*ThriftSourceProtocolClient) AppendBatch ¶

func (p *ThriftSourceProtocolClient) AppendBatch(ctx context.Context, events []*ThriftFlumeEvent) (r Status, err error)

Parameters:

Events

type ThriftSourceProtocolProcessor ¶

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

func (*ThriftSourceProtocolProcessor) AddToProcessorMap ¶

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

func (*ThriftSourceProtocolProcessor) GetProcessorFunction ¶

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

func (*ThriftSourceProtocolProcessor) Process ¶

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

func (*ThriftSourceProtocolProcessor) ProcessorMap ¶

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
thrift_source_protocol-remote

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