Documentation
¶
Index ¶
- func MessageEntry(nodeID string, args ...string) *log.Entry
- func NodeEntry(nodeID string) *log.Entry
- func ReadBool(reader io.Reader) (bool, error)
- func ReadBytes(reader io.Reader) ([]byte, error)
- func ReadMap(reader io.Reader, m interface{}, f interface{}) error
- func ReadSlice(reader io.Reader, s interface{}, f interface{}) error
- func ReadValue(reader io.Reader, f interface{}) (interface{}, error)
- func ReadVarInt(reader io.Reader) (int, error)
- func ReadVarInt32(reader io.Reader) (int32, error)
- func ReadVarInt64(reader io.Reader) (int64, error)
- func ReadVarUint(reader io.Reader) (uint, error)
- func ReadVarUint32(reader io.Reader) (uint32, error)
- func ReadVarUint64(reader io.Reader) (uint64, error)
- func RequestEntry(nodeID string, args ...string) *log.Entry
- func ResponseEntry(nodeID string, args ...string) *log.Entry
- func ServiceEntry(nodeID string, serviceNamespace string, serviceName string, sessionID uint64) *log.Entry
- func SessionEntry(nodeID string, sessionID uint64) *log.Entry
- func StreamEntry(nodeID string, sessionID uint64, streamID uint64) *log.Entry
- func WriteBool(writer io.Writer, b bool) error
- func WriteBytes(writer io.Writer, bytes []byte) error
- func WriteMap(writer io.Writer, m interface{}, f interface{}) error
- func WriteSlice(writer io.Writer, s interface{}, f interface{}) error
- func WriteValue(writer io.Writer, value interface{}, f interface{}) error
- func WriteVarInt(writer io.Writer, i int) error
- func WriteVarInt32(writer io.Writer, i int32) error
- func WriteVarInt64(writer io.Writer, x int64) error
- func WriteVarUint(writer io.Writer, i uint) error
- func WriteVarUint32(writer io.Writer, i uint32) error
- func WriteVarUint64(writer io.Writer, x uint64) error
- type Ready
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MessageEntry ¶
MessageEntry returns a log Entry with additional fields containing request metadata
func NodeEntry ¶
NodeEntry returns a log Entry with additional fields containing the given node metadata
func ReadVarInt ¶
ReadVarInt reads a signed integer from the given reader
func ReadVarInt32 ¶
ReadVarInt32 reads a signed 32-bit integer from the given reader
func ReadVarInt64 ¶
ReadVarInt64 reads a signed variable length integer from the given reader
func ReadVarUint ¶
ReadVarUint reads an unsigned integer from the given reader
func ReadVarUint32 ¶
ReadVarUint32 reads an unsigned 32-bit integer from the given reader
func ReadVarUint64 ¶
ReadVarUint64 reads an unsigned variable length integer from the given reader
func RequestEntry ¶
RequestEntry returns a log Entry with additional fields containing request metadata
func ResponseEntry ¶
ResponseEntry returns a log Entry with additional fields containing response metadata
func ServiceEntry ¶
func ServiceEntry(nodeID string, serviceNamespace string, serviceName string, sessionID uint64) *log.Entry
ServiceEntry returns a log Entry with additional fields containing the given service metadata
func SessionEntry ¶
SessionEntry returns a log Entry with additional fields containing the given session metadata
func StreamEntry ¶
StreamEntry returns a log Entry with additional fields containing the given stream metadata
func WriteBytes ¶
WriteBytes writes a byte slice to the given writer
func WriteSlice ¶
WriteSlice writes a slice the the given writer
func WriteValue ¶
WriteValue writes the given value to the given writer
func WriteVarInt ¶
WriteVarInt writes a signed integer to the given writer
func WriteVarInt32 ¶
WriteVarInt32 writes a signed 32-bit integer to the given writer
func WriteVarInt64 ¶
WriteVarInt64 writes a signed variable length integer to the given writer
func WriteVarUint ¶
WriteVarUint writes an unsigned integer to the given writer
func WriteVarUint32 ¶
WriteVarUint32 writes an unsigned 32-bit integer to the given writer
Types ¶
type Ready ¶
type Ready interface {
// Set ensures that future readiness probes will indicate that the operator
// is ready.
Set() error
// Unset ensures that future readiness probes will indicate that the
// operator is not ready.
Unset() error
}
Ready holds state about whether the operator is ready and communicates that to a Kubernetes readiness probe.
func NewFileReady ¶
func NewFileReady() Ready
NewFileReady returns a Ready that uses the presence of a file on disk to communicate whether the operator is ready. The operator's Pod definition should include a readinessProbe of "exec" type that calls "stat /tmp/operator-sdk-ready".
Source Files