test

package
v1.9.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 2, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Code generated by github.com/actgardner/gogen-avro/v10. DO NOT EDIT.

  • SOURCE:
  • example.avsc

Code generated by github.com/actgardner/gogen-avro/v10. DO NOT EDIT.

  • SOURCE:
  • example.avsc

Code generated by github.com/actgardner/gogen-avro/v10. DO NOT EDIT.

  • SOURCE:
  • nested.avsc

Code generated by github.com/actgardner/gogen-avro/v10. DO NOT EDIT.

  • SOURCE:
  • nested.avsc

Code generated by github.com/actgardner/gogen-avro/v10. DO NOT EDIT.

  • SOURCE:
  • nested.avsc

Code generated by github.com/actgardner/gogen-avro/v10. DO NOT EDIT.

  • SOURCE:
  • recursive.avsc

Code generated by github.com/actgardner/gogen-avro/v10. DO NOT EDIT.

  • SOURCE:
  • recursive.avsc

Index

Constants

View Source
const DemoSchemaAvroCRC64Fingerprint = "\xc4V\xa9\x04ʛf\xad"
View Source
const NestedRecordAvroCRC64Fingerprint = "\x81\x8d\xc3K?\xe83\xcc"
View Source
const NestedTestRecordAvroCRC64Fingerprint = "b{m\\D\xbe\xaa\x96"
View Source
const NumberRecordAvroCRC64Fingerprint = "\xf4Zu\xd5Nt'~"
View Source
const RecursiveUnionTestRecordAvroCRC64Fingerprint = "\xc6U)C\v\x8a\xa6\x89"

Variables

View Source
var (
	Status_name = map[int32]string{
		0: "ACTIVE",
		1: "INACTIVE",
	}
	Status_value = map[string]int32{
		"ACTIVE":   0,
		"INACTIVE": 1,
	}
)

Enum value maps for Status.

View Source
var (
	NestedMessage_InnerEnum_name = map[int32]string{
		0: "ZERO",
	}
	NestedMessage_InnerEnum_value = map[string]int32{
		"ZERO":      0,
		"ALSO_ZERO": 0,
	}
)

Enum value maps for NestedMessage_InnerEnum.

View Source
var File_cycle_proto protoreflect.FileDescriptor
View Source
var File_schemaregistry_test_proto_example_proto protoreflect.FileDescriptor
View Source
var File_schemaregistry_test_proto_nested_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Author

type Author struct {
	Name  string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id    int32    `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Works []string `protobuf:"bytes,4,rep,name=works,proto3" json:"works,omitempty"`
	// contains filtered or unexported fields
}

func (*Author) Descriptor deprecated

func (*Author) Descriptor() ([]byte, []int)

Deprecated: Use Author.ProtoReflect.Descriptor instead.

func (*Author) GetId

func (x *Author) GetId() int32

func (*Author) GetName

func (x *Author) GetName() string

func (*Author) GetWorks

func (x *Author) GetWorks() []string

func (*Author) ProtoMessage

func (*Author) ProtoMessage()

func (*Author) ProtoReflect

func (x *Author) ProtoReflect() protoreflect.Message

func (*Author) Reset

func (x *Author) Reset()

func (*Author) String

func (x *Author) String() string

type Bytes

type Bytes []byte

func (Bytes) MarshalJSON

func (b Bytes) MarshalJSON() ([]byte, error)

func (*Bytes) UnmarshalJSON

func (b *Bytes) UnmarshalJSON(data []byte) error

type BytesWrapper

type BytesWrapper struct {
	Target *Bytes
}

func (BytesWrapper) AppendArray

func (b BytesWrapper) AppendArray() types.Field

func (BytesWrapper) AppendMap

func (b BytesWrapper) AppendMap(key string) types.Field

func (BytesWrapper) Finalize

func (b BytesWrapper) Finalize()

func (BytesWrapper) Get

func (b BytesWrapper) Get(i int) types.Field

func (BytesWrapper) HintSize

func (b BytesWrapper) HintSize(int)

func (BytesWrapper) NullField

func (b BytesWrapper) NullField(int)

func (BytesWrapper) SetBoolean

func (b BytesWrapper) SetBoolean(v bool)

func (BytesWrapper) SetBytes

func (b BytesWrapper) SetBytes(v []byte)

func (BytesWrapper) SetDefault

func (b BytesWrapper) SetDefault(i int)

func (BytesWrapper) SetDouble

func (b BytesWrapper) SetDouble(v float64)

func (BytesWrapper) SetFloat

func (b BytesWrapper) SetFloat(v float32)

func (BytesWrapper) SetInt

func (b BytesWrapper) SetInt(v int32)

func (BytesWrapper) SetLong

func (b BytesWrapper) SetLong(v int64)

func (BytesWrapper) SetString

func (b BytesWrapper) SetString(v string)

func (BytesWrapper) SetUnionElem

func (b BytesWrapper) SetUnionElem(v int64)

type ComplexType

type ComplexType struct {

	// Types that are assignable to SomeVal:
	//	*ComplexType_OneId
	//	*ComplexType_OtherId
	SomeVal  isComplexType_SomeVal `protobuf_oneof:"some_val"`
	IsActive bool                  `protobuf:"varint,3,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	// contains filtered or unexported fields
}

func (*ComplexType) Descriptor deprecated

func (*ComplexType) Descriptor() ([]byte, []int)

Deprecated: Use ComplexType.ProtoReflect.Descriptor instead.

func (*ComplexType) GetIsActive

func (x *ComplexType) GetIsActive() bool

func (*ComplexType) GetOneId

func (x *ComplexType) GetOneId() string

func (*ComplexType) GetOtherId

func (x *ComplexType) GetOtherId() int32

func (*ComplexType) GetSomeVal

func (m *ComplexType) GetSomeVal() isComplexType_SomeVal

func (*ComplexType) ProtoMessage

func (*ComplexType) ProtoMessage()

func (*ComplexType) ProtoReflect

func (x *ComplexType) ProtoReflect() protoreflect.Message

func (*ComplexType) Reset

func (x *ComplexType) Reset()

func (*ComplexType) String

func (x *ComplexType) String() string

type ComplexType_OneId

type ComplexType_OneId struct {
	OneId string `protobuf:"bytes,1,opt,name=one_id,json=oneId,proto3,oneof"`
}

type ComplexType_OtherId

type ComplexType_OtherId struct {
	OtherId int32 `protobuf:"varint,2,opt,name=other_id,json=otherId,proto3,oneof"`
}

type DemoSchema

type DemoSchema struct {
	IntField int32 `json:"IntField"`

	DoubleField float64 `json:"DoubleField"`

	StringField string `json:"StringField"`

	BoolField bool `json:"BoolField"`

	BytesField Bytes `json:"BytesField"`
}

func DeserializeDemoSchema

func DeserializeDemoSchema(r io.Reader) (DemoSchema, error)

func DeserializeDemoSchemaFromSchema

func DeserializeDemoSchemaFromSchema(r io.Reader, schema string) (DemoSchema, error)

func NewDemoSchema

func NewDemoSchema() DemoSchema

func (DemoSchema) AppendArray

func (_ DemoSchema) AppendArray() types.Field

func (DemoSchema) AppendMap

func (_ DemoSchema) AppendMap(key string) types.Field

func (DemoSchema) AvroCRC64Fingerprint

func (_ DemoSchema) AvroCRC64Fingerprint() []byte

func (DemoSchema) Finalize

func (_ DemoSchema) Finalize()

func (*DemoSchema) Get

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

func (DemoSchema) HintSize

func (_ DemoSchema) HintSize(int)

func (DemoSchema) MarshalJSON

func (r DemoSchema) MarshalJSON() ([]byte, error)

func (*DemoSchema) NullField

func (r *DemoSchema) NullField(i int)

func (DemoSchema) Schema

func (r DemoSchema) Schema() string

func (DemoSchema) SchemaName

func (r DemoSchema) SchemaName() string

func (DemoSchema) Serialize

func (r DemoSchema) Serialize(w io.Writer) error

func (DemoSchema) SetBoolean

func (_ DemoSchema) SetBoolean(v bool)

func (DemoSchema) SetBytes

func (_ DemoSchema) SetBytes(v []byte)

func (*DemoSchema) SetDefault

func (r *DemoSchema) SetDefault(i int)

func (DemoSchema) SetDouble

func (_ DemoSchema) SetDouble(v float64)

func (DemoSchema) SetFloat

func (_ DemoSchema) SetFloat(v float32)

func (DemoSchema) SetInt

func (_ DemoSchema) SetInt(v int32)

func (DemoSchema) SetLong

func (_ DemoSchema) SetLong(v int64)

func (DemoSchema) SetString

func (_ DemoSchema) SetString(v string)

func (DemoSchema) SetUnionElem

func (_ DemoSchema) SetUnionElem(v int64)

func (*DemoSchema) UnmarshalJSON

func (r *DemoSchema) UnmarshalJSON(data []byte) error

type DependencyMessage

type DependencyMessage struct {
	IsActive     bool         `protobuf:"varint,1,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	TestMesssage *TestMessage `protobuf:"bytes,2,opt,name=test_messsage,json=testMesssage,proto3" json:"test_messsage,omitempty"`
	// contains filtered or unexported fields
}

func (*DependencyMessage) Descriptor deprecated

func (*DependencyMessage) Descriptor() ([]byte, []int)

Deprecated: Use DependencyMessage.ProtoReflect.Descriptor instead.

func (*DependencyMessage) GetIsActive

func (x *DependencyMessage) GetIsActive() bool

func (*DependencyMessage) GetTestMesssage

func (x *DependencyMessage) GetTestMesssage() *TestMessage

func (*DependencyMessage) ProtoMessage

func (*DependencyMessage) ProtoMessage()

func (*DependencyMessage) ProtoReflect

func (x *DependencyMessage) ProtoReflect() protoreflect.Message

func (*DependencyMessage) Reset

func (x *DependencyMessage) Reset()

func (*DependencyMessage) String

func (x *DependencyMessage) String() string

type LinkedList

type LinkedList struct {
	Value int32       `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Next  *LinkedList `protobuf:"bytes,10,opt,name=next,proto3" json:"next,omitempty"`
	// contains filtered or unexported fields
}

func (*LinkedList) Descriptor deprecated

func (*LinkedList) Descriptor() ([]byte, []int)

Deprecated: Use LinkedList.ProtoReflect.Descriptor instead.

func (*LinkedList) GetNext

func (x *LinkedList) GetNext() *LinkedList

func (*LinkedList) GetValue

func (x *LinkedList) GetValue() int32

func (*LinkedList) ProtoMessage

func (*LinkedList) ProtoMessage()

func (*LinkedList) ProtoReflect

func (x *LinkedList) ProtoReflect() protoreflect.Message

func (*LinkedList) Reset

func (x *LinkedList) Reset()

func (*LinkedList) String

func (x *LinkedList) String() string

type MessageId

type MessageId struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageId) Descriptor deprecated

func (*MessageId) Descriptor() ([]byte, []int)

Deprecated: Use MessageId.ProtoReflect.Descriptor instead.

func (*MessageId) GetId

func (x *MessageId) GetId() string

func (*MessageId) ProtoMessage

func (*MessageId) ProtoMessage()

func (*MessageId) ProtoReflect

func (x *MessageId) ProtoReflect() protoreflect.Message

func (*MessageId) Reset

func (x *MessageId) Reset()

func (*MessageId) String

func (x *MessageId) String() string

type NestedMessage

type NestedMessage struct {
	UserId            *UserId                     `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	IsActive          bool                        `protobuf:"varint,2,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	ExperimentsActive []string                    `protobuf:"bytes,3,rep,name=experiments_active,json=experimentsActive,proto3" json:"experiments_active,omitempty"`
	UpdatedAt         *timestamppb.Timestamp      `protobuf:"bytes,4,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Status            Status                      `protobuf:"varint,5,opt,name=status,proto3,enum=io.confluent.kafka.serializers.protobuf.test.Status" json:"status,omitempty"`
	ComplexType       *ComplexType                `protobuf:"bytes,6,opt,name=complex_type,json=complexType,proto3" json:"complex_type,omitempty"`
	MapType           map[string]string           `` /* 170-byte string literal not displayed */
	Inner             *NestedMessage_InnerMessage `protobuf:"bytes,8,opt,name=inner,proto3" json:"inner,omitempty"`
	// contains filtered or unexported fields
}

Complex message using nested protos and repeated fields

func (*NestedMessage) Descriptor deprecated

func (*NestedMessage) Descriptor() ([]byte, []int)

Deprecated: Use NestedMessage.ProtoReflect.Descriptor instead.

func (*NestedMessage) GetComplexType

func (x *NestedMessage) GetComplexType() *ComplexType

func (*NestedMessage) GetExperimentsActive

func (x *NestedMessage) GetExperimentsActive() []string

func (*NestedMessage) GetInner

func (*NestedMessage) GetIsActive

func (x *NestedMessage) GetIsActive() bool

func (*NestedMessage) GetMapType

func (x *NestedMessage) GetMapType() map[string]string

func (*NestedMessage) GetStatus

func (x *NestedMessage) GetStatus() Status

func (*NestedMessage) GetUpdatedAt

func (x *NestedMessage) GetUpdatedAt() *timestamppb.Timestamp

func (*NestedMessage) GetUserId

func (x *NestedMessage) GetUserId() *UserId

func (*NestedMessage) ProtoMessage

func (*NestedMessage) ProtoMessage()

func (*NestedMessage) ProtoReflect

func (x *NestedMessage) ProtoReflect() protoreflect.Message

func (*NestedMessage) Reset

func (x *NestedMessage) Reset()

func (*NestedMessage) String

func (x *NestedMessage) String() string

type NestedMessage_InnerEnum

type NestedMessage_InnerEnum int32
const (
	NestedMessage_ZERO      NestedMessage_InnerEnum = 0
	NestedMessage_ALSO_ZERO NestedMessage_InnerEnum = 0
)

func (NestedMessage_InnerEnum) Descriptor

func (NestedMessage_InnerEnum) Enum

func (NestedMessage_InnerEnum) EnumDescriptor deprecated

func (NestedMessage_InnerEnum) EnumDescriptor() ([]byte, []int)

Deprecated: Use NestedMessage_InnerEnum.Descriptor instead.

func (NestedMessage_InnerEnum) Number

func (NestedMessage_InnerEnum) String

func (x NestedMessage_InnerEnum) String() string

func (NestedMessage_InnerEnum) Type

type NestedMessage_InnerMessage

type NestedMessage_InnerMessage struct {
	Id  string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Ids []int32 `protobuf:"varint,2,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*NestedMessage_InnerMessage) Descriptor deprecated

func (*NestedMessage_InnerMessage) Descriptor() ([]byte, []int)

Deprecated: Use NestedMessage_InnerMessage.ProtoReflect.Descriptor instead.

func (*NestedMessage_InnerMessage) GetId

func (*NestedMessage_InnerMessage) GetIds

func (x *NestedMessage_InnerMessage) GetIds() []int32

func (*NestedMessage_InnerMessage) ProtoMessage

func (*NestedMessage_InnerMessage) ProtoMessage()

func (*NestedMessage_InnerMessage) ProtoReflect

func (*NestedMessage_InnerMessage) Reset

func (x *NestedMessage_InnerMessage) Reset()

func (*NestedMessage_InnerMessage) String

func (x *NestedMessage_InnerMessage) String() string

type NestedRecord

type NestedRecord struct {
	StringField string `json:"StringField"`

	BoolField bool `json:"BoolField"`

	BytesField Bytes `json:"BytesField"`
}

func DeserializeNestedRecord

func DeserializeNestedRecord(r io.Reader) (NestedRecord, error)

func DeserializeNestedRecordFromSchema

func DeserializeNestedRecordFromSchema(r io.Reader, schema string) (NestedRecord, error)

func NewNestedRecord

func NewNestedRecord() NestedRecord

func (NestedRecord) AppendArray

func (_ NestedRecord) AppendArray() types.Field

func (NestedRecord) AppendMap

func (_ NestedRecord) AppendMap(key string) types.Field

func (NestedRecord) AvroCRC64Fingerprint

func (_ NestedRecord) AvroCRC64Fingerprint() []byte

func (NestedRecord) Finalize

func (_ NestedRecord) Finalize()

func (*NestedRecord) Get

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

func (NestedRecord) HintSize

func (_ NestedRecord) HintSize(int)

func (NestedRecord) MarshalJSON

func (r NestedRecord) MarshalJSON() ([]byte, error)

func (*NestedRecord) NullField

func (r *NestedRecord) NullField(i int)

func (NestedRecord) Schema

func (r NestedRecord) Schema() string

func (NestedRecord) SchemaName

func (r NestedRecord) SchemaName() string

func (NestedRecord) Serialize

func (r NestedRecord) Serialize(w io.Writer) error

func (NestedRecord) SetBoolean

func (_ NestedRecord) SetBoolean(v bool)

func (NestedRecord) SetBytes

func (_ NestedRecord) SetBytes(v []byte)

func (*NestedRecord) SetDefault

func (r *NestedRecord) SetDefault(i int)

func (NestedRecord) SetDouble

func (_ NestedRecord) SetDouble(v float64)

func (NestedRecord) SetFloat

func (_ NestedRecord) SetFloat(v float32)

func (NestedRecord) SetInt

func (_ NestedRecord) SetInt(v int32)

func (NestedRecord) SetLong

func (_ NestedRecord) SetLong(v int64)

func (NestedRecord) SetString

func (_ NestedRecord) SetString(v string)

func (NestedRecord) SetUnionElem

func (_ NestedRecord) SetUnionElem(v int64)

func (*NestedRecord) UnmarshalJSON

func (r *NestedRecord) UnmarshalJSON(data []byte) error

type NestedTestRecord

type NestedTestRecord struct {
	NumberField NumberRecord `json:"NumberField"`

	OtherField NestedRecord `json:"OtherField"`
}

func DeserializeNestedTestRecord

func DeserializeNestedTestRecord(r io.Reader) (NestedTestRecord, error)

func DeserializeNestedTestRecordFromSchema

func DeserializeNestedTestRecordFromSchema(r io.Reader, schema string) (NestedTestRecord, error)

func NewNestedTestRecord

func NewNestedTestRecord() NestedTestRecord

func (NestedTestRecord) AppendArray

func (_ NestedTestRecord) AppendArray() types.Field

func (NestedTestRecord) AppendMap

func (_ NestedTestRecord) AppendMap(key string) types.Field

func (NestedTestRecord) AvroCRC64Fingerprint

func (_ NestedTestRecord) AvroCRC64Fingerprint() []byte

func (NestedTestRecord) Finalize

func (_ NestedTestRecord) Finalize()

func (*NestedTestRecord) Get

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

func (NestedTestRecord) HintSize

func (_ NestedTestRecord) HintSize(int)

func (NestedTestRecord) MarshalJSON

func (r NestedTestRecord) MarshalJSON() ([]byte, error)

func (*NestedTestRecord) NullField

func (r *NestedTestRecord) NullField(i int)

func (NestedTestRecord) Schema

func (r NestedTestRecord) Schema() string

func (NestedTestRecord) SchemaName

func (r NestedTestRecord) SchemaName() string

func (NestedTestRecord) Serialize

func (r NestedTestRecord) Serialize(w io.Writer) error

func (NestedTestRecord) SetBoolean

func (_ NestedTestRecord) SetBoolean(v bool)

func (NestedTestRecord) SetBytes

func (_ NestedTestRecord) SetBytes(v []byte)

func (*NestedTestRecord) SetDefault

func (r *NestedTestRecord) SetDefault(i int)

func (NestedTestRecord) SetDouble

func (_ NestedTestRecord) SetDouble(v float64)

func (NestedTestRecord) SetFloat

func (_ NestedTestRecord) SetFloat(v float32)

func (NestedTestRecord) SetInt

func (_ NestedTestRecord) SetInt(v int32)

func (NestedTestRecord) SetLong

func (_ NestedTestRecord) SetLong(v int64)

func (NestedTestRecord) SetString

func (_ NestedTestRecord) SetString(v string)

func (NestedTestRecord) SetUnionElem

func (_ NestedTestRecord) SetUnionElem(v int64)

func (*NestedTestRecord) UnmarshalJSON

func (r *NestedTestRecord) UnmarshalJSON(data []byte) error

type NumberRecord

type NumberRecord struct {
	IntField int32 `json:"IntField"`

	LongField int64 `json:"LongField"`

	FloatField float32 `json:"FloatField"`

	DoubleField float64 `json:"DoubleField"`
}

func DeserializeNumberRecord

func DeserializeNumberRecord(r io.Reader) (NumberRecord, error)

func DeserializeNumberRecordFromSchema

func DeserializeNumberRecordFromSchema(r io.Reader, schema string) (NumberRecord, error)

func NewNumberRecord

func NewNumberRecord() NumberRecord

func (NumberRecord) AppendArray

func (_ NumberRecord) AppendArray() types.Field

func (NumberRecord) AppendMap

func (_ NumberRecord) AppendMap(key string) types.Field

func (NumberRecord) AvroCRC64Fingerprint

func (_ NumberRecord) AvroCRC64Fingerprint() []byte

func (NumberRecord) Finalize

func (_ NumberRecord) Finalize()

func (*NumberRecord) Get

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

func (NumberRecord) HintSize

func (_ NumberRecord) HintSize(int)

func (NumberRecord) MarshalJSON

func (r NumberRecord) MarshalJSON() ([]byte, error)

func (*NumberRecord) NullField

func (r *NumberRecord) NullField(i int)

func (NumberRecord) Schema

func (r NumberRecord) Schema() string

func (NumberRecord) SchemaName

func (r NumberRecord) SchemaName() string

func (NumberRecord) Serialize

func (r NumberRecord) Serialize(w io.Writer) error

func (NumberRecord) SetBoolean

func (_ NumberRecord) SetBoolean(v bool)

func (NumberRecord) SetBytes

func (_ NumberRecord) SetBytes(v []byte)

func (*NumberRecord) SetDefault

func (r *NumberRecord) SetDefault(i int)

func (NumberRecord) SetDouble

func (_ NumberRecord) SetDouble(v float64)

func (NumberRecord) SetFloat

func (_ NumberRecord) SetFloat(v float32)

func (NumberRecord) SetInt

func (_ NumberRecord) SetInt(v int32)

func (NumberRecord) SetLong

func (_ NumberRecord) SetLong(v int64)

func (NumberRecord) SetString

func (_ NumberRecord) SetString(v string)

func (NumberRecord) SetUnionElem

func (_ NumberRecord) SetUnionElem(v int64)

func (*NumberRecord) UnmarshalJSON

func (r *NumberRecord) UnmarshalJSON(data []byte) error

type Pizza

type Pizza struct {
	Size     string   `protobuf:"bytes,1,opt,name=size,proto3" json:"size,omitempty"`
	Toppings []string `protobuf:"bytes,2,rep,name=toppings,proto3" json:"toppings,omitempty"`
	// contains filtered or unexported fields
}

func (*Pizza) Descriptor deprecated

func (*Pizza) Descriptor() ([]byte, []int)

Deprecated: Use Pizza.ProtoReflect.Descriptor instead.

func (*Pizza) GetSize

func (x *Pizza) GetSize() string

func (*Pizza) GetToppings

func (x *Pizza) GetToppings() []string

func (*Pizza) ProtoMessage

func (*Pizza) ProtoMessage()

func (*Pizza) ProtoReflect

func (x *Pizza) ProtoReflect() protoreflect.Message

func (*Pizza) Reset

func (x *Pizza) Reset()

func (*Pizza) String

func (x *Pizza) String() string

type RecursiveUnionTestRecord

type RecursiveUnionTestRecord struct {
	RecursiveField *UnionNullRecursiveUnionTestRecord `json:"RecursiveField"`
}

func DeserializeRecursiveUnionTestRecord

func DeserializeRecursiveUnionTestRecord(r io.Reader) (RecursiveUnionTestRecord, error)

func DeserializeRecursiveUnionTestRecordFromSchema

func DeserializeRecursiveUnionTestRecordFromSchema(r io.Reader, schema string) (RecursiveUnionTestRecord, error)

func NewRecursiveUnionTestRecord

func NewRecursiveUnionTestRecord() RecursiveUnionTestRecord

func (RecursiveUnionTestRecord) AppendArray

func (_ RecursiveUnionTestRecord) AppendArray() types.Field

func (RecursiveUnionTestRecord) AppendMap

func (_ RecursiveUnionTestRecord) AppendMap(key string) types.Field

func (RecursiveUnionTestRecord) AvroCRC64Fingerprint

func (_ RecursiveUnionTestRecord) AvroCRC64Fingerprint() []byte

func (RecursiveUnionTestRecord) Finalize

func (_ RecursiveUnionTestRecord) Finalize()

func (*RecursiveUnionTestRecord) Get

func (RecursiveUnionTestRecord) HintSize

func (_ RecursiveUnionTestRecord) HintSize(int)

func (RecursiveUnionTestRecord) MarshalJSON

func (r RecursiveUnionTestRecord) MarshalJSON() ([]byte, error)

func (*RecursiveUnionTestRecord) NullField

func (r *RecursiveUnionTestRecord) NullField(i int)

func (RecursiveUnionTestRecord) Schema

func (r RecursiveUnionTestRecord) Schema() string

func (RecursiveUnionTestRecord) SchemaName

func (r RecursiveUnionTestRecord) SchemaName() string

func (RecursiveUnionTestRecord) Serialize

func (r RecursiveUnionTestRecord) Serialize(w io.Writer) error

func (RecursiveUnionTestRecord) SetBoolean

func (_ RecursiveUnionTestRecord) SetBoolean(v bool)

func (RecursiveUnionTestRecord) SetBytes

func (_ RecursiveUnionTestRecord) SetBytes(v []byte)

func (*RecursiveUnionTestRecord) SetDefault

func (r *RecursiveUnionTestRecord) SetDefault(i int)

func (RecursiveUnionTestRecord) SetDouble

func (_ RecursiveUnionTestRecord) SetDouble(v float64)

func (RecursiveUnionTestRecord) SetFloat

func (_ RecursiveUnionTestRecord) SetFloat(v float32)

func (RecursiveUnionTestRecord) SetInt

func (_ RecursiveUnionTestRecord) SetInt(v int32)

func (RecursiveUnionTestRecord) SetLong

func (_ RecursiveUnionTestRecord) SetLong(v int64)

func (RecursiveUnionTestRecord) SetString

func (_ RecursiveUnionTestRecord) SetString(v string)

func (RecursiveUnionTestRecord) SetUnionElem

func (_ RecursiveUnionTestRecord) SetUnionElem(v int64)

func (*RecursiveUnionTestRecord) UnmarshalJSON

func (r *RecursiveUnionTestRecord) UnmarshalJSON(data []byte) error

type Status

type Status int32
const (
	Status_ACTIVE   Status = 0
	Status_INACTIVE Status = 1
)

func (Status) Descriptor

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated

func (Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Status.Descriptor instead.

func (Status) Number

func (x Status) Number() protoreflect.EnumNumber

func (Status) String

func (x Status) String() string

func (Status) Type

func (Status) Type() protoreflect.EnumType

type TestMessage

type TestMessage struct {
	TestString   string  `protobuf:"bytes,1,opt,name=test_string,json=testString,proto3" json:"test_string,omitempty"`
	TestBool     bool    `protobuf:"varint,2,opt,name=test_bool,json=testBool,proto3" json:"test_bool,omitempty"`
	TestBytes    []byte  `protobuf:"bytes,3,opt,name=test_bytes,json=testBytes,proto3" json:"test_bytes,omitempty"`
	TestDouble   float64 `protobuf:"fixed64,4,opt,name=test_double,json=testDouble,proto3" json:"test_double,omitempty"`
	TestFloat    float32 `protobuf:"fixed32,5,opt,name=test_float,json=testFloat,proto3" json:"test_float,omitempty"`
	TestFixed32  uint32  `protobuf:"fixed32,6,opt,name=test_fixed32,json=testFixed32,proto3" json:"test_fixed32,omitempty"`
	TestFixed64  uint64  `protobuf:"fixed64,7,opt,name=test_fixed64,json=testFixed64,proto3" json:"test_fixed64,omitempty"`
	TestInt32    int32   `protobuf:"varint,8,opt,name=test_int32,json=testInt32,proto3" json:"test_int32,omitempty"`
	TestInt64    int64   `protobuf:"varint,9,opt,name=test_int64,json=testInt64,proto3" json:"test_int64,omitempty"`
	TestSfixed32 int32   `protobuf:"fixed32,10,opt,name=test_sfixed32,json=testSfixed32,proto3" json:"test_sfixed32,omitempty"`
	TestSfixed64 int64   `protobuf:"fixed64,11,opt,name=test_sfixed64,json=testSfixed64,proto3" json:"test_sfixed64,omitempty"`
	TestSint32   int32   `protobuf:"zigzag32,12,opt,name=test_sint32,json=testSint32,proto3" json:"test_sint32,omitempty"`
	TestSint64   int64   `protobuf:"zigzag64,13,opt,name=test_sint64,json=testSint64,proto3" json:"test_sint64,omitempty"`
	TestUint32   uint32  `protobuf:"varint,14,opt,name=test_uint32,json=testUint32,proto3" json:"test_uint32,omitempty"`
	TestUint64   uint64  `protobuf:"varint,15,opt,name=test_uint64,json=testUint64,proto3" json:"test_uint64,omitempty"`
	// contains filtered or unexported fields
}

func (*TestMessage) Descriptor deprecated

func (*TestMessage) Descriptor() ([]byte, []int)

Deprecated: Use TestMessage.ProtoReflect.Descriptor instead.

func (*TestMessage) GetTestBool

func (x *TestMessage) GetTestBool() bool

func (*TestMessage) GetTestBytes

func (x *TestMessage) GetTestBytes() []byte

func (*TestMessage) GetTestDouble

func (x *TestMessage) GetTestDouble() float64

func (*TestMessage) GetTestFixed32

func (x *TestMessage) GetTestFixed32() uint32

func (*TestMessage) GetTestFixed64

func (x *TestMessage) GetTestFixed64() uint64

func (*TestMessage) GetTestFloat

func (x *TestMessage) GetTestFloat() float32

func (*TestMessage) GetTestInt32

func (x *TestMessage) GetTestInt32() int32

func (*TestMessage) GetTestInt64

func (x *TestMessage) GetTestInt64() int64

func (*TestMessage) GetTestSfixed32

func (x *TestMessage) GetTestSfixed32() int32

func (*TestMessage) GetTestSfixed64

func (x *TestMessage) GetTestSfixed64() int64

func (*TestMessage) GetTestSint32

func (x *TestMessage) GetTestSint32() int32

func (*TestMessage) GetTestSint64

func (x *TestMessage) GetTestSint64() int64

func (*TestMessage) GetTestString

func (x *TestMessage) GetTestString() string

func (*TestMessage) GetTestUint32

func (x *TestMessage) GetTestUint32() uint32

func (*TestMessage) GetTestUint64

func (x *TestMessage) GetTestUint64() uint64

func (*TestMessage) ProtoMessage

func (*TestMessage) ProtoMessage()

func (*TestMessage) ProtoReflect

func (x *TestMessage) ProtoReflect() protoreflect.Message

func (*TestMessage) Reset

func (x *TestMessage) Reset()

func (*TestMessage) String

func (x *TestMessage) String() string

type UnionNullRecursiveUnionTestRecord

type UnionNullRecursiveUnionTestRecord struct {
	Null                     *types.NullVal
	RecursiveUnionTestRecord RecursiveUnionTestRecord
	UnionType                UnionNullRecursiveUnionTestRecordTypeEnum
}

func DeserializeUnionNullRecursiveUnionTestRecord

func DeserializeUnionNullRecursiveUnionTestRecord(r io.Reader) (*UnionNullRecursiveUnionTestRecord, error)

func DeserializeUnionNullRecursiveUnionTestRecordFromSchema

func DeserializeUnionNullRecursiveUnionTestRecordFromSchema(r io.Reader, schema string) (*UnionNullRecursiveUnionTestRecord, error)

func NewUnionNullRecursiveUnionTestRecord

func NewUnionNullRecursiveUnionTestRecord() *UnionNullRecursiveUnionTestRecord

func (*UnionNullRecursiveUnionTestRecord) AppendArray

func (*UnionNullRecursiveUnionTestRecord) AppendMap

func (*UnionNullRecursiveUnionTestRecord) Finalize

func (_ *UnionNullRecursiveUnionTestRecord) Finalize()

func (*UnionNullRecursiveUnionTestRecord) Get

func (*UnionNullRecursiveUnionTestRecord) HintSize

func (_ *UnionNullRecursiveUnionTestRecord) HintSize(i int)

func (*UnionNullRecursiveUnionTestRecord) MarshalJSON

func (r *UnionNullRecursiveUnionTestRecord) MarshalJSON() ([]byte, error)

func (*UnionNullRecursiveUnionTestRecord) NullField

func (_ *UnionNullRecursiveUnionTestRecord) NullField(i int)

func (*UnionNullRecursiveUnionTestRecord) Schema

func (*UnionNullRecursiveUnionTestRecord) Serialize

func (*UnionNullRecursiveUnionTestRecord) SetBoolean

func (_ *UnionNullRecursiveUnionTestRecord) SetBoolean(v bool)

func (*UnionNullRecursiveUnionTestRecord) SetBytes

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

func (*UnionNullRecursiveUnionTestRecord) SetDefault

func (_ *UnionNullRecursiveUnionTestRecord) SetDefault(i int)

func (*UnionNullRecursiveUnionTestRecord) SetDouble

func (*UnionNullRecursiveUnionTestRecord) SetFloat

func (*UnionNullRecursiveUnionTestRecord) SetInt

func (*UnionNullRecursiveUnionTestRecord) SetLong

func (*UnionNullRecursiveUnionTestRecord) SetString

func (_ *UnionNullRecursiveUnionTestRecord) SetString(v string)

func (*UnionNullRecursiveUnionTestRecord) UnmarshalJSON

func (r *UnionNullRecursiveUnionTestRecord) UnmarshalJSON(data []byte) error

type UnionNullRecursiveUnionTestRecordTypeEnum

type UnionNullRecursiveUnionTestRecordTypeEnum int
const (
	UnionNullRecursiveUnionTestRecordTypeEnumRecursiveUnionTestRecord UnionNullRecursiveUnionTestRecordTypeEnum = 1
)

type UserId

type UserId struct {

	// Types that are assignable to UserId:
	//	*UserId_KafkaUserId
	//	*UserId_OtherUserId
	//	*UserId_AnotherId
	UserId isUserId_UserId `protobuf_oneof:"user_id"`
	// contains filtered or unexported fields
}

func (*UserId) Descriptor deprecated

func (*UserId) Descriptor() ([]byte, []int)

Deprecated: Use UserId.ProtoReflect.Descriptor instead.

func (*UserId) GetAnotherId

func (x *UserId) GetAnotherId() *MessageId

func (*UserId) GetKafkaUserId

func (x *UserId) GetKafkaUserId() string

func (*UserId) GetOtherUserId

func (x *UserId) GetOtherUserId() int32

func (*UserId) GetUserId

func (m *UserId) GetUserId() isUserId_UserId

func (*UserId) ProtoMessage

func (*UserId) ProtoMessage()

func (*UserId) ProtoReflect

func (x *UserId) ProtoReflect() protoreflect.Message

func (*UserId) Reset

func (x *UserId) Reset()

func (*UserId) String

func (x *UserId) String() string

type UserId_AnotherId

type UserId_AnotherId struct {
	AnotherId *MessageId `protobuf:"bytes,3,opt,name=another_id,json=anotherId,proto3,oneof"`
}

type UserId_KafkaUserId

type UserId_KafkaUserId struct {
	KafkaUserId string `protobuf:"bytes,1,opt,name=kafka_user_id,json=kafkaUserId,proto3,oneof"`
}

type UserId_OtherUserId

type UserId_OtherUserId struct {
	OtherUserId int32 `protobuf:"varint,2,opt,name=other_user_id,json=otherUserId,proto3,oneof"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL