Support for the message_set_wire_format message option.

Get gets the value pointed at by p.

Get gets the value pointed at by *v.

IsNil reports whether *v is nil.

writeHeader panics if len(hdr) is less than 8.

Clone returns a deep copy of a protocol buffer.

Close closes the underlying connection.

DefaultPackageName returns the package name printed for the object. If its file is in a different package, it returns the package name we're using for

Delete deletes a key/value pair from the store

Dial connects to the Redis server at the given network and address using the specified options.

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

GetExtension parses and returns the given extension of pb. If the extension is not present and has no default value it returns ErrMissingExtension.

Init is called once after data structures are built but before code generation begins.

Int coerces into an int

MustFloat64 guarantees the return of a `float64` (with optional default) useful when you explicitly want a `float64` in a single value return context

MustUInt64 guarantees the return of an `uint64` (with optional default) useful when you explicitly want an `uint64` in a single value return context:

PSubscribe subscribes the connection to the given patterns.

Publish creates a new Command to write a message to a given topic

Set modifies `Json` map by `key` and `value` Useful for changing single key/value in a `Json` object easily.

SetBuf replaces the internal buffer with the slice, ready for unmarshaling the contents of the slice.

Stats retrieves the current connection and message statistics for a Consumer

String returns the fully-qualified address

StringArray type asserts to an `array` of `string`

Subscribe subscribes the connection to the specified channels.

UnmarshalMerge parses the protocol buffer representation in buf and writes the decoded result to pb. If the struct underlying pb does not match the d

Write buffers p internally, encoding and writing a block to the underlying buffer if the buffer grows beyond MaxBlockSize bytes. The returned int wil

WriteTo implements the WriterTo interface and serializes the message into the supplied producer. It is suggested that the target Writer is buffered t

benchmarkDecode runs a benchmark that repeatedly decoded snappy framed bytes enc. The length of the decoded result in each iteration must equal size.

benchmarkEncode benchmarks the speed at which bytes can be copied from bs into writers created by enc.

decodeExtension decodes an extension encoded in b.

actually do the redis command

emitLiteral writes a literal chunk and returns the number of bytes written.

longer than any conceivable sizeVarint Encode a struct, preceded by its encoded length (as a varint).

encodeStreamBytes is like encodeStream but operates on a byte slice. encodeStreamBytes ensures that long streams are not maximally compressed if buffe

v1 and v2 are known to have the same type. prop may be nil.

Returns an actual Option instance. @param option the name of the option, assumed to be normed already (!) @return the requested Option instance @thro

goPackageName returns the Go package name to use in the generated Go file. The result explicit reports whether the name came from an option go_packag

And now lots of helper functions. Is c an ASCII lower-case letter?

Is this field repeated?

Everything but the last element of the full type name, CamelCased. The values of type Foo.Bar are call Foo_value1... not Foo_Bar_value1... .

make an HTTP req to one of the configured nsqlookupd instances to discover which nsqd's provide the topic we are consuming. initiate a connection to

会阻塞但保证能发送成功

Sets an option's value and creates the option if it doesn't exist. @param option the option's name @param value the option's value @throws IllegalAr

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

<code>optional uint64 offset = 2;</code> <p> <pre> 数据起始偏移量 </pre>

Bool returns the address of a *bool field in the struct.

BoolVal returns the address of a bool field in the struct.

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

NewAt returns the reflect.Value for a pointer to a field in the struct.

String returns the address of a *string field in the struct.

StringSlice returns the address of a []string field in the struct.

StringVal returns the address of a string field in the struct.