Documentation
¶
Index ¶
- Variables
- type LogEntry
- type ResultCode
- type Scribe
- type ScribeClient
- type ScribeLogArgs
- type ScribeLogResult
- 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 LogEntry ¶
type LogEntry struct { Category string `thrift:"category,1" json:"category"` Message string `thrift:"message,2" json:"message"` }
Attributes:
- Category
- Message
func NewLogEntry ¶
func NewLogEntry() *LogEntry
func (*LogEntry) GetCategory ¶
func (*LogEntry) GetMessage ¶
type ResultCode ¶
type ResultCode int64
const ( ResultCode_OK ResultCode = 0 ResultCode_TRY_LATER ResultCode = 1 )
var ScribeLogResult_Success_DEFAULT ResultCode
func ResultCodeFromString ¶
func ResultCodeFromString(s string) (ResultCode, error)
func ResultCodePtr ¶
func ResultCodePtr(v ResultCode) *ResultCode
func (ResultCode) MarshalText ¶
func (p ResultCode) MarshalText() ([]byte, error)
func (ResultCode) String ¶
func (p ResultCode) String() string
func (*ResultCode) UnmarshalText ¶
func (p *ResultCode) UnmarshalText(text []byte) error
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 ScribeLogArgs ¶
type ScribeLogArgs struct {
Messages []*LogEntry `thrift:"messages,1" json:"messages"`
}
Attributes:
- Messages
func NewScribeLogArgs ¶
func NewScribeLogArgs() *ScribeLogArgs
func (*ScribeLogArgs) GetMessages ¶
func (p *ScribeLogArgs) GetMessages() []*LogEntry
func (*ScribeLogArgs) String ¶
func (p *ScribeLogArgs) String() string
type ScribeLogResult ¶
type ScribeLogResult struct {
Success *ResultCode `thrift:"success,0" json:"success,omitempty"`
}
Attributes:
- Success
func NewScribeLogResult ¶
func NewScribeLogResult() *ScribeLogResult
func (*ScribeLogResult) GetSuccess ¶
func (p *ScribeLogResult) GetSuccess() ResultCode
func (*ScribeLogResult) IsSetSuccess ¶
func (p *ScribeLogResult) IsSetSuccess() bool
func (*ScribeLogResult) String ¶
func (p *ScribeLogResult) String() string
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
Click to show internal directories.
Click to hide internal directories.