CheckGet returns a pointer to a new `Json` object and a `bool` identifying success or failure useful for chained operations when success is important

Close idempotently initiates connection close

CompactTextString is the same as CompactText, but returns the string directly.

Decode returns the decoded form of src. The returned slice may be a sub- slice of dst if dst was large enough to hold the entire decoded block. Otherw

DeferredPublish creates a new Command to write a message to a given topic where the message will queue at the channel level until the timeout expires

DescName returns the variable name used for the generated descriptor.

DialReadTimeout specifies the timeout for reading a single command reply.

DialWriteTimeout specifies the timeout for writing a single command.

DisconnectFromNSQD closes the connection to and removes the specified `nsqd` address from the list

FileOf return the FileDescriptor for this FileDescriptorProto.

Finish sends a FIN command to the nsqd which sent this message

Flush encodes and writes a block with the contents of w's internal buffer to the underlying writer even if the buffer does not contain a full block of

IsAutoResponseDisabled indicates whether or not this message will be responded to automatically

IsClosing indicates whether or not the connection is currently in the processing of gracefully closing

LastRDY returns the previously set RDY count

Implements the json.Marshaler interface.

MaxEncodedLen returns the maximum length of a snappy block, given its uncompressed length.

MaxRDY returns the nsqd negotiated maximum RDY count that it will accept for this connection

MultiGet is a batch version of Get

MultiPublish creates a new Command to write more than one message to a given topic (useful for high-throughput situations to avoid roundtrips and satu

NewConn returns a new Conn instance

NewFromReader returns a *Json by decoding from an io.Reader

Nop creates a new Command that has no effect server side. Commonly used to respond to heartbeats

OnResponse is called when the connection receives a FrameTypeResponse from nsqd

PUnsubscribe unsubscribes the connection from the given patterns, or from all of them if none is given.

Ping causes the Producer to connect to it's configured nsqd (if not already connected) and send a `Nop` command, returning any error that might occur.

Read performs a deadlined read on the underlying TCP connection

Requeue sends a REQ command to the nsqd which sent this message, using the supplied delay. A delay of -1 will automatically calculate based on the nu

Size returns the encoded size of a protocol buffer.

TypeName returns the elements of the dotted type name. The package name is not part of this name.

Unmarshal parses the protocol buffer representation in the Buffer and places the decoded result in pb. If the struct underlying pb does not match the

Implements the json.Unmarshaler interface.

UnmarshalString will populate the fields of a protocol buffer based on a JSON string. This function is lenient and will decode any options permutation

Validate checks that all values are within specified min/max ranges

Adds a section if it doesn't exist yet. @param name the name of the section @return <code>true</code> if the section didn't already exist @throws Ill

baseName returns the last path element of the name, with the last dotted suffix removed.

checkExtensionTypes checks that the given extension is valid for pb.

将文件列表files组装好入hdfs，组装可能是poseidon模式 这时t是logMap的key，是truncate后的时间，比如2016-06-06-12-15，一个t对应的全部文件都入到hadoop中一个文件中

Decode a slice of structs ([]*struct).

decodeLength decodes a 24-bit (3-byte) little-endian length from b.

decodedLen returns the length of the decoded block and the number of bytes that the length header occupied.

dottedSlice turns a sliced name into a dotted name.

Encode something, preceded by its encoded length (as a varint).

encodeExtensionMap encodes any unmarshaled (unencoded) extensions in m.

v1 and v2 are known to have the same type.

fieldDefault returns the scalarField for field type ft. sf will be nil if the field can not have a default. nestedMessage will be true if this is a ne

generateClientSignature returns the client-side signature for a method.