Documentation
¶
Index ¶
- Variables
- type LogArgs
- type LogEntry
- func (p *LogEntry) GetCategory() string
- func (p *LogEntry) GetMessage() string
- func (p *LogEntry) Read(iprot thrift.TProtocol) error
- func (p *LogEntry) ReadField1(iprot thrift.TProtocol) error
- func (p *LogEntry) ReadField2(iprot thrift.TProtocol) error
- func (p *LogEntry) String() string
- func (p *LogEntry) Write(oprot thrift.TProtocol) error
- type LogResult
- type ResultCode
- type Scribe
- type ScribeClient
- type ScribeProcessor
- func (p *ScribeProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
- func (p *ScribeProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
- func (p *ScribeProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
- func (p *ScribeProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
Constants ¶
This section is empty.
Variables ¶
View Source
var GoUnusedProtection__ int
Functions ¶
This section is empty.
Types ¶
type LogArgs ¶
type LogArgs struct {
Messages []*LogEntry `thrift:"messages,1" json:"messages"`
}
func NewLogArgs ¶
func NewLogArgs() *LogArgs
func (*LogArgs) GetMessages ¶
type LogEntry ¶
type LogEntry struct {
Category string `thrift:"category,1" json:"category"`
Message string `thrift:"message,2" json:"message"`
}
func NewLogEntry ¶
func NewLogEntry() *LogEntry
func (*LogEntry) GetCategory ¶
func (*LogEntry) GetMessage ¶
type LogResult ¶
type LogResult struct {
Success *ResultCode `thrift:"success,0" json:"success"`
}
func NewLogResult ¶
func NewLogResult() *LogResult
func (*LogResult) GetSuccess ¶
func (p *LogResult) GetSuccess() ResultCode
func (*LogResult) IsSetSuccess ¶
type ResultCode ¶
type ResultCode int64
const ( ResultCode_OK ResultCode = 0 ResultCode_TRY_LATER ResultCode = 1 )
var LogResult_Success_DEFAULT ResultCode
func ResultCodeFromString ¶
func ResultCodeFromString(s string) (ResultCode, error)
func ResultCodePtr ¶
func ResultCodePtr(v ResultCode) *ResultCode
func (ResultCode) String ¶
func (p ResultCode) String() string
type Scribe ¶
type Scribe interface {
// Parameters:
// - Messages
Log(messages []*LogEntry) (r ResultCode, err error)
}
type ScribeClient ¶
type ScribeClient struct {
Transport thrift.TTransport
ProtocolFactory thrift.TProtocolFactory
InputProtocol thrift.TProtocol
OutputProtocol thrift.TProtocol
SeqId int32
}
func NewScribeClientFactory ¶
func NewScribeClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ScribeClient
func NewScribeClientProtocol ¶
func NewScribeClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ScribeClient
func (*ScribeClient) Log ¶
func (p *ScribeClient) Log(messages []*LogEntry) (r ResultCode, err error)
Parameters:
- Messages
type ScribeProcessor ¶
type ScribeProcessor struct {
// contains filtered or unexported fields
}
func NewScribeProcessor ¶
func NewScribeProcessor(handler Scribe) *ScribeProcessor
func (*ScribeProcessor) AddToProcessorMap ¶
func (p *ScribeProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
func (*ScribeProcessor) GetProcessorFunction ¶
func (p *ScribeProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
func (*ScribeProcessor) Process ¶
func (p *ScribeProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
func (*ScribeProcessor) ProcessorMap ¶
func (p *ScribeProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
Source Files
Click to show internal directories.
Click to hide internal directories.