Documentation ¶
Index ¶
Constants ¶
View Source
const ( MSG_KEY_PREFIX = 80 // This many bytes in every rcv message are for the key. KTRANSLATE_PROTO = 100 KTRANSLATE_MAP_PROTO = 101 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KflowFormat ¶
func NewFormat ¶
func NewFormat(log logger.Underlying, compression kt.Compression) (*KflowFormat, error)
func (*KflowFormat) From ¶
func (f *KflowFormat) From(raw *kt.Output) ([]map[string]interface{}, error)
Click to show internal directories.
Click to hide internal directories.