Documentation ¶
Index ¶
- func NewFlumeEvent() *flume.ThriftFlumeEvent
- type FlumeClient
- func (self *FlumeClient) Append(ctx context.Context, event *flume.ThriftFlumeEvent) error
- func (self *FlumeClient) AppendBatch(ctx context.Context, events []*flume.ThriftFlumeEvent) error
- func (self *FlumeClient) Connect() error
- func (self *FlumeClient) Destroy()
- func (self *FlumeClient) HostPort() string
- func (self *FlumeClient) IsAlive() bool
- type Status
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFlumeEvent ¶
func NewFlumeEvent() *flume.ThriftFlumeEvent
Types ¶
type FlumeClient ¶
type FlumeClient struct {
// contains filtered or unexported fields
}
func NewFlumeClient ¶
func NewFlumeClient(host string, port int) *FlumeClient
func (*FlumeClient) Append ¶
func (self *FlumeClient) Append(ctx context.Context, event *flume.ThriftFlumeEvent) error
func (*FlumeClient) AppendBatch ¶
func (self *FlumeClient) AppendBatch(ctx context.Context, events []*flume.ThriftFlumeEvent) error
func (*FlumeClient) Connect ¶
func (self *FlumeClient) Connect() error
func (*FlumeClient) Destroy ¶
func (self *FlumeClient) Destroy()
func (*FlumeClient) HostPort ¶
func (self *FlumeClient) HostPort() string
func (*FlumeClient) IsAlive ¶
func (self *FlumeClient) IsAlive() bool
Click to show internal directories.
Click to hide internal directories.