authevents

Documentation

Index

• func NewUserRegisteredWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type ByteWriter
• type StringWriter
• type UserRegistered
  • func DeserializeUserRegistered(r io.Reader) (*UserRegistered, error)
  • func DeserializeUserRegisteredFromSchema(r io.Reader, schema string) (*UserRegistered, error)
  • func NewUserRegistered() *UserRegistered
  • func (_ *UserRegistered) AppendArray() types.Field
  • func (_ *UserRegistered) AppendMap(key string) types.Field
  • func (_ *UserRegistered) Finalize()
  • func (r *UserRegistered) Get(i int) types.Field
  • func (r *UserRegistered) Schema() string
  • func (r *UserRegistered) SchemaName() string
  • func (r *UserRegistered) Serialize(w io.Writer) error
  • func (_ *UserRegistered) SetBoolean(v bool)
  • func (_ *UserRegistered) SetBytes(v []byte)
  • func (r *UserRegistered) SetDefault(i int)
  • func (_ *UserRegistered) SetDouble(v float64)
  • func (_ *UserRegistered) SetFloat(v float32)
  • func (_ *UserRegistered) SetInt(v int32)
  • func (_ *UserRegistered) SetLong(v int64)
  • func (_ *UserRegistered) SetString(v string)
  • func (_ *UserRegistered) SetUnionElem(v int64)
• type UserRegisteredReader
  • func NewUserRegisteredReader(r io.Reader) (*UserRegisteredReader, error)
  • func (r *UserRegisteredReader) Read() (*UserRegistered, error)

Functions

func NewUserRegisteredWriter

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

Types

type ByteWriter

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

type StringWriter

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

type UserRegistered

type UserRegistered struct {
	ID           string
	TimeUnixMs   int64
	Email        string
	PasswordHash string
}

func DeserializeUserRegistered

func DeserializeUserRegistered(r io.Reader) (*UserRegistered, error)

func DeserializeUserRegisteredFromSchema

func DeserializeUserRegisteredFromSchema(r io.Reader, schema string) (*UserRegistered, error)

func NewUserRegistered

func NewUserRegistered() *UserRegistered

func (*UserRegistered) AppendArray

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

func (*UserRegistered) AppendMap

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

func (*UserRegistered) Finalize

func (_ *UserRegistered) Finalize()

func (*UserRegistered) Get

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

func (*UserRegistered) Schema

func (r *UserRegistered) Schema() string

func (*UserRegistered) SchemaName

func (r *UserRegistered) SchemaName() string

func (*UserRegistered) Serialize

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

func (*UserRegistered) SetBoolean

func (_ *UserRegistered) SetBoolean(v bool)

func (*UserRegistered) SetBytes

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

func (*UserRegistered) SetDefault

func (r *UserRegistered) SetDefault(i int)

func (*UserRegistered) SetDouble

func (_ *UserRegistered) SetDouble(v float64)

func (*UserRegistered) SetFloat

func (_ *UserRegistered) SetFloat(v float32)

func (*UserRegistered) SetInt

func (_ *UserRegistered) SetInt(v int32)

func (*UserRegistered) SetLong

func (_ *UserRegistered) SetLong(v int64)

func (*UserRegistered) SetString

func (_ *UserRegistered) SetString(v string)

func (*UserRegistered) SetUnionElem

func (_ *UserRegistered) SetUnionElem(v int64)

type UserRegisteredReader

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

func NewUserRegisteredReader

func NewUserRegisteredReader(r io.Reader) (*UserRegisteredReader, error)

func (*UserRegisteredReader) Read

func (r *UserRegisteredReader) Read() (*UserRegistered, error)