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_dep_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
View Source 
var File_test_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 (x *NestedMessage) GetInner() *NestedMessage_InnerMessage

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) Descriptor() protoreflect.EnumDescriptor

func (NestedMessage_InnerEnum) Enum 

func (x NestedMessage_InnerEnum) Enum() *NestedMessage_InnerEnum

func (NestedMessage_InnerEnum) EnumDescriptor deprecated 

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

Deprecated: Use NestedMessage_InnerEnum.Descriptor instead.

func (NestedMessage_InnerEnum) Number 

func (x NestedMessage_InnerEnum) Number() protoreflect.EnumNumber

func (NestedMessage_InnerEnum) String 

func (x NestedMessage_InnerEnum) String() string

func (NestedMessage_InnerEnum) Type 

func (NestedMessage_InnerEnum) Type() protoreflect.EnumType

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 (x *NestedMessage_InnerMessage) GetId() string

func (*NestedMessage_InnerMessage) GetIds 

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

func (*NestedMessage_InnerMessage) ProtoMessage 

func (*NestedMessage_InnerMessage) ProtoMessage()

func (*NestedMessage_InnerMessage) ProtoReflect 

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

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 (r *RecursiveUnionTestRecord) Get(i int) types.Field

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) AppendArray() types.Field

func (*UnionNullRecursiveUnionTestRecord) AppendMap 

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

func (*UnionNullRecursiveUnionTestRecord) Finalize 

func (_ *UnionNullRecursiveUnionTestRecord) Finalize()

func (*UnionNullRecursiveUnionTestRecord) Get 

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

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 (r *UnionNullRecursiveUnionTestRecord) Schema() string

func (*UnionNullRecursiveUnionTestRecord) Serialize 

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

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) SetDouble(v float64)

func (*UnionNullRecursiveUnionTestRecord) SetFloat 

func (_ *UnionNullRecursiveUnionTestRecord) SetFloat(v float32)

func (*UnionNullRecursiveUnionTestRecord) SetInt 

func (_ *UnionNullRecursiveUnionTestRecord) SetInt(v int32)

func (*UnionNullRecursiveUnionTestRecord) SetLong 

func (r *UnionNullRecursiveUnionTestRecord) SetLong(v int64)

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"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.