record

Documentation

Overview

Package record is bp-go-lib's kafka record files path. Depend on https://github.com/actgardner/gogen-avro. Install: go install github.com/actgardner/gogen-avro/gogen-avro. Usage: gogen-avro [--package=<package name>] <output directory> <avro schema files>

Index

• func NewExampleRequestWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• func NewExampleResponseWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type ArrayStringWrapper
  • func (r *ArrayStringWrapper) AppendArray() types.Field
  • func (_ *ArrayStringWrapper) AppendMap(key string) types.Field
  • func (_ *ArrayStringWrapper) Finalize()
  • func (_ *ArrayStringWrapper) Get(i int) types.Field
  • func (_ *ArrayStringWrapper) SetBoolean(v bool)
  • func (_ *ArrayStringWrapper) SetBytes(v []byte)
  • func (_ *ArrayStringWrapper) SetDefault(i int)
  • func (_ *ArrayStringWrapper) SetDouble(v float64)
  • func (_ *ArrayStringWrapper) SetFloat(v float32)
  • func (_ *ArrayStringWrapper) SetInt(v int32)
  • func (_ *ArrayStringWrapper) SetLong(v int64)
  • func (_ *ArrayStringWrapper) SetString(v string)
  • func (_ *ArrayStringWrapper) SetUnionElem(v int64)
• type ByteWriter
• type ExampleRequest
  • func DeserializeExampleRequest(r io.Reader) (*ExampleRequest, error)
  • func NewExampleRequest() *ExampleRequest
  • func (_ *ExampleRequest) AppendArray() types.Field
  • func (_ *ExampleRequest) AppendMap(key string) types.Field
  • func (_ *ExampleRequest) Finalize()
  • func (r *ExampleRequest) Get(i int) types.Field
  • func (r *ExampleRequest) Schema() string
  • func (r *ExampleRequest) SchemaName() string
  • func (r *ExampleRequest) Serialize(w io.Writer) error
  • func (_ *ExampleRequest) SetBoolean(v bool)
  • func (_ *ExampleRequest) SetBytes(v []byte)
  • func (r *ExampleRequest) SetDefault(i int)
  • func (_ *ExampleRequest) SetDouble(v float64)
  • func (_ *ExampleRequest) SetFloat(v float32)
  • func (_ *ExampleRequest) SetInt(v int32)
  • func (_ *ExampleRequest) SetLong(v int64)
  • func (_ *ExampleRequest) SetString(v string)
  • func (_ *ExampleRequest) SetUnionElem(v int64)
• type ExampleRequestReader
  • func NewExampleRequestReader(r io.Reader) (*ExampleRequestReader, error)
  • func (r *ExampleRequestReader) Read() (*ExampleRequest, error)
• type ExampleResponse
  • func DeserializeExampleResponse(r io.Reader) (*ExampleResponse, error)
  • func NewExampleResponse() *ExampleResponse
  • func (_ *ExampleResponse) AppendArray() types.Field
  • func (_ *ExampleResponse) AppendMap(key string) types.Field
  • func (_ *ExampleResponse) Finalize()
  • func (r *ExampleResponse) Get(i int) types.Field
  • func (r *ExampleResponse) Schema() string
  • func (r *ExampleResponse) SchemaName() string
  • func (r *ExampleResponse) Serialize(w io.Writer) error
  • func (_ *ExampleResponse) SetBoolean(v bool)
  • func (_ *ExampleResponse) SetBytes(v []byte)
  • func (r *ExampleResponse) SetDefault(i int)
  • func (_ *ExampleResponse) SetDouble(v float64)
  • func (_ *ExampleResponse) SetFloat(v float32)
  • func (_ *ExampleResponse) SetInt(v int32)
  • func (_ *ExampleResponse) SetLong(v int64)
  • func (_ *ExampleResponse) SetString(v string)
  • func (_ *ExampleResponse) SetUnionElem(v int64)
• type ExampleResponseReader
  • func NewExampleResponseReader(r io.Reader) (*ExampleResponseReader, error)
  • func (r *ExampleResponseReader) Read() (*ExampleResponse, error)
• type StringWriter

Functions

func NewExampleRequestWriter

func NewExampleRequestWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)

func NewExampleResponseWriter

func NewExampleResponseWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)

Types

type ArrayStringWrapper

type ArrayStringWrapper []string

func (*ArrayStringWrapper) AppendArray

func (r *ArrayStringWrapper) AppendArray() types.Field

func (*ArrayStringWrapper) AppendMap

func (_ *ArrayStringWrapper) AppendMap(key string) types.Field

func (*ArrayStringWrapper) Finalize

func (_ *ArrayStringWrapper) Finalize()

func (*ArrayStringWrapper) Get

func (_ *ArrayStringWrapper) Get(i int) types.Field

func (*ArrayStringWrapper) SetBoolean

func (_ *ArrayStringWrapper) SetBoolean(v bool)

func (*ArrayStringWrapper) SetBytes

func (_ *ArrayStringWrapper) SetBytes(v []byte)

func (*ArrayStringWrapper) SetDefault

func (_ *ArrayStringWrapper) SetDefault(i int)

func (*ArrayStringWrapper) SetDouble

func (_ *ArrayStringWrapper) SetDouble(v float64)

func (*ArrayStringWrapper) SetFloat

func (_ *ArrayStringWrapper) SetFloat(v float32)

func (*ArrayStringWrapper) SetInt

func (_ *ArrayStringWrapper) SetInt(v int32)

func (*ArrayStringWrapper) SetLong

func (_ *ArrayStringWrapper) SetLong(v int64)

func (*ArrayStringWrapper) SetString

func (_ *ArrayStringWrapper) SetString(v string)

func (*ArrayStringWrapper) SetUnionElem

func (_ *ArrayStringWrapper) SetUnionElem(v int64)

type ByteWriter

type ByteWriter interface {
	Grow(int)
	WriteByte(byte) error
}

type ExampleRequest

type ExampleRequest struct {
	JobId   string
	Tag     string
	Configs []string
}

func DeserializeExampleRequest

func DeserializeExampleRequest(r io.Reader) (*ExampleRequest, error)

func NewExampleRequest

func NewExampleRequest() *ExampleRequest

func (*ExampleRequest) AppendArray

func (_ *ExampleRequest) AppendArray() types.Field

func (*ExampleRequest) AppendMap

func (_ *ExampleRequest) AppendMap(key string) types.Field

func (*ExampleRequest) Finalize

func (_ *ExampleRequest) Finalize()

func (*ExampleRequest) Get

func (r *ExampleRequest) Get(i int) types.Field

func (*ExampleRequest) Schema

func (r *ExampleRequest) Schema() string

func (*ExampleRequest) SchemaName

func (r *ExampleRequest) SchemaName() string

func (*ExampleRequest) Serialize

func (r *ExampleRequest) Serialize(w io.Writer) error

func (*ExampleRequest) SetBoolean

func (_ *ExampleRequest) SetBoolean(v bool)

func (*ExampleRequest) SetBytes

func (_ *ExampleRequest) SetBytes(v []byte)

func (*ExampleRequest) SetDefault

func (r *ExampleRequest) SetDefault(i int)

func (*ExampleRequest) SetDouble

func (_ *ExampleRequest) SetDouble(v float64)

func (*ExampleRequest) SetFloat

func (_ *ExampleRequest) SetFloat(v float32)

func (*ExampleRequest) SetInt

func (_ *ExampleRequest) SetInt(v int32)

func (*ExampleRequest) SetLong

func (_ *ExampleRequest) SetLong(v int64)

func (*ExampleRequest) SetString

func (_ *ExampleRequest) SetString(v string)

func (*ExampleRequest) SetUnionElem

func (_ *ExampleRequest) SetUnionElem(v int64)

type ExampleRequestReader

type ExampleRequestReader struct {
	// contains filtered or unexported fields
}

func NewExampleRequestReader

func NewExampleRequestReader(r io.Reader) (*ExampleRequestReader, error)

func (*ExampleRequestReader) Read

func (r *ExampleRequestReader) Read() (*ExampleRequest, error)

type ExampleResponse

type ExampleResponse struct {
	JobId    string
	Progress int64
	Error    string
}

func DeserializeExampleResponse

func DeserializeExampleResponse(r io.Reader) (*ExampleResponse, error)

func NewExampleResponse

func NewExampleResponse() *ExampleResponse

func (*ExampleResponse) AppendArray

func (_ *ExampleResponse) AppendArray() types.Field

func (*ExampleResponse) AppendMap

func (_ *ExampleResponse) AppendMap(key string) types.Field

func (*ExampleResponse) Finalize

func (_ *ExampleResponse) Finalize()

func (*ExampleResponse) Get

func (r *ExampleResponse) Get(i int) types.Field

func (*ExampleResponse) Schema

func (r *ExampleResponse) Schema() string

func (*ExampleResponse) SchemaName

func (r *ExampleResponse) SchemaName() string

func (*ExampleResponse) Serialize

func (r *ExampleResponse) Serialize(w io.Writer) error

func (*ExampleResponse) SetBoolean

func (_ *ExampleResponse) SetBoolean(v bool)

func (*ExampleResponse) SetBytes

func (_ *ExampleResponse) SetBytes(v []byte)

func (*ExampleResponse) SetDefault

func (r *ExampleResponse) SetDefault(i int)

func (*ExampleResponse) SetDouble

func (_ *ExampleResponse) SetDouble(v float64)

func (*ExampleResponse) SetFloat

func (_ *ExampleResponse) SetFloat(v float32)

func (*ExampleResponse) SetInt

func (_ *ExampleResponse) SetInt(v int32)

func (*ExampleResponse) SetLong

func (_ *ExampleResponse) SetLong(v int64)

func (*ExampleResponse) SetString

func (_ *ExampleResponse) SetString(v string)

func (*ExampleResponse) SetUnionElem

func (_ *ExampleResponse) SetUnionElem(v int64)

type ExampleResponseReader

type ExampleResponseReader struct {
	// contains filtered or unexported fields
}

func NewExampleResponseReader

func NewExampleResponseReader(r io.Reader) (*ExampleResponseReader, error)

func (*ExampleResponseReader) Read

func (r *ExampleResponseReader) Read() (*ExampleResponse, error)

type StringWriter

type StringWriter interface {
	WriteString(string) (int, error)
}