<code>optional string path = 1;</code> <p> <pre> HDFS路径，例如：/the/path/to/log/business/2014-04-22/00/log1.zwt.2014-04-22-00-17.gz, 实际离线存储的时候会做一定的压缩，例如不存

CamelCaseSlice is like CamelCase, but the argument is a slice of strings to be joined with "_".

DebugPrint dumps the encoded data in b in a debugging format with a header including the string s. Used in testing but made available for general debu

These are not ValueDecoders: they produce an array of bytes or a string. bytes, embedded messages DecodeRawBytes reads a count-delimited byte buffer f

dial wraps DialDefaultServer() with a more suitable function name for examples.

opaqueChunk returns an opaque b chunk (e.g. padding 0xfe) with length n (total length, n+4 bytes). practically useless but good enough for testing. t

field returns the given field in the struct as a reflect value.

* * Helper routines for simplifying the creation of optional fields of basic type. */ Bool is a helper routine that allocates a new bool value to st

ConnectToNSQD takes a nsqd address to connect directly to. It is recommended to use ConnectToNSQLookupd so that topics are discovered automatically.

Float64 coerces into a float64

IsValid reports whether the field identifier is valid.

Set takes an option as a string and a value as an interface and attempts to set the appropriate configuration option. It attempts to coerce the value

Returns a section by name or <code>null</code> if not found. @param name the section's name @return the section

Removes an option from a section if it exists. Will not remove options from the common section if it's not directly addressed. @param section the sec

Word32Slice returns the address of a []int32, []uint32, []float32, or []enum field in the struct.

NewJson returns a pointer to a new `Json` object after unmarshaling `body` bytes

NewProducer returns an instance of Producer for the specified address The only valid way to create a Config is via NewConfig, using a struct literal

UnmarshalText reads a protocol buffer in Text format. UnmarshalText resets pb before starting to unmarshal, so any existing data in pb is always remov

Checks whether a section with a particular name exists in this instance. @param name the name of the section @return true if the section exists

Read one line from the InputStream into the given Text. @param str the object to store the given line (without newline) @param maxLineL

shouldContinue reports whether encoding should continue upon encountering the given error. If the error is RequiredNotSetError, shouldContinue returns

Interface returns the struct pointer, assumed to have element type t, as an interface value.

ifield returns the given field in the struct as an interface value.

MustBool guarantees the return of a `bool` (with optional default) useful when you explicitly want a `bool` in a single value return context: myFunc(

MustStringArray guarantees the return of a `[]string` (with optional default) useful when you want to interate over array values in a succinct manner

Name identifies the plugin.

SetLogger assigns the logger to use as well as a level The logger parameter is an interface that requires the following method to be implemented (suc

Stop will initiate a graceful stop of the Consumer (permanent) NOTE: receive on StopChan to block until this process completes

Stop initiates a graceful stop of the Producer (permanent) NOTE: this blocks until completion

Bytes returns the address of a []byte field in the struct.

Given a type name defined in a .proto, return its name as we will print it.

Array type asserts to an `array`

CamelCase returns the CamelCased name. If there is an interior underscore followed by a lower case letter, drop the underscore and convert the letter

Error reports a problem, including an error, and exits the program.

GetIndex returns a pointer to a new `Json` object for `index` in its `array` representation this is the analog to Get when accessing elements of a js

GoType returns a string representing the type name, and the wire type

Map type asserts to `map`

MustMap guarantees the return of a `map[string]interface{}` (with optional default) useful when you want to interate over map values in a succinct ma

NewBufferedWriter allocates and returns a BufferedWriter with an internal buffer of MaxBlockSize bytes. If an error occurs writing a block to w, all

NewMessage creates a Message, initializes some metadata, and returns a pointer

PrintComments prints any comments from the source .proto file. The path is a comma-separated list of integers. It returns an indication of whether any

Set sets a value with key where the key exists or not

<code>optional uint32 length = 3;</code> <p> <pre> 数据长度 </pre>

AddFlat returns the result of appending the flattened value of v to args. Maps are flattened by appending the alternating keys and map values to args

AddHandler sets the Handler for messages received by this Consumer. This can be called multiple times to add additional handlers. Handler will have a

Close flushes w's internal buffer and tears down internal data structures. After a successful call to Close method calls on w return an error. Close

EncodeRawBytes writes a count-delimited byte buffer to the Buffer. This is the format used for the bytes protocol buffer type and for embedded message

Get gets a connection. The application must close the returned connection.

ReadUnpackedResponse reads and parses data from the underlying TCP connection according to the NSQ TCP protocol spec and returns the frameType, data o

Uint64 coerces into an uint64

Values is a helper that converts an array command reply to a []interface{}. If err is not equal to nil, then Values returns nil, err. Otherwise, Value

WriteCommand is a goroutine safe method to write a Command to this connection, and flush.

<code>repeated .proto.DocId docIds = 1;</code> <p> <pre> 该分词所关联的 Document ID。按照 docId 升序排列 为了方便 protobuf 的 varint 压缩存储，采用差分数据来存储 差分数据：后一个数据的存储值等于它的原始值

randBytes reads size bytes from the computer's cryptographic random source. the resulting bytes have approximately maximal entropy and are effectively

<code>optional uint64 docId = 1;</code> <p> <pre> Document ID </pre>

BoolSlice returns the address of a []bool field in the struct.

GetStructPointer reads a *struct field in the struct.

不会阻塞但不保证能发送成功

unmarshalType does the work of unmarshaling a structure.