Versions in this module Expand all Collapse all v0 v0.0.4 Sep 7, 2022 v0.0.2 Aug 30, 2022 v0.0.1 Aug 30, 2022 Changes in this version + const DemoSchemaAvroCRC64Fingerprint + const NestedRecordAvroCRC64Fingerprint + const NestedTestRecordAvroCRC64Fingerprint + const NumberRecordAvroCRC64Fingerprint + const RecursiveUnionTestRecordAvroCRC64Fingerprint + var File_cycle_proto protoreflect.FileDescriptor + var File_dep_proto protoreflect.FileDescriptor + var File_schemaregistry_test_proto_example_proto protoreflect.FileDescriptor + var File_schemaregistry_test_proto_nested_proto protoreflect.FileDescriptor + var File_test_proto protoreflect.FileDescriptor + var NestedMessage_InnerEnum_name = map[int32]string + var NestedMessage_InnerEnum_value = map[string]int32 + var Status_name = map[int32]string + var Status_value = map[string]int32 + type Author struct + Id int32 + Name string + Works []string + func (*Author) Descriptor() ([]byte, []int) + func (*Author) ProtoMessage() + func (x *Author) GetId() int32 + func (x *Author) GetName() string + func (x *Author) GetWorks() []string + func (x *Author) ProtoReflect() protoreflect.Message + func (x *Author) Reset() + func (x *Author) String() string + type Bytes []byte + func (b *Bytes) UnmarshalJSON(data []byte) error + func (b Bytes) MarshalJSON() ([]byte, error) + type BytesWrapper struct + Target *Bytes + func (b BytesWrapper) AppendArray() types.Field + func (b BytesWrapper) AppendMap(key string) types.Field + func (b BytesWrapper) Finalize() + func (b BytesWrapper) Get(i int) types.Field + func (b BytesWrapper) HintSize(int) + func (b BytesWrapper) NullField(int) + func (b BytesWrapper) SetBoolean(v bool) + func (b BytesWrapper) SetBytes(v []byte) + func (b BytesWrapper) SetDefault(i int) + func (b BytesWrapper) SetDouble(v float64) + func (b BytesWrapper) SetFloat(v float32) + func (b BytesWrapper) SetInt(v int32) + func (b BytesWrapper) SetLong(v int64) + func (b BytesWrapper) SetString(v string) + func (b BytesWrapper) SetUnionElem(v int64) + type ComplexType struct + IsActive bool + SomeVal isComplexType_SomeVal + func (*ComplexType) Descriptor() ([]byte, []int) + func (*ComplexType) ProtoMessage() + func (m *ComplexType) GetSomeVal() isComplexType_SomeVal + func (x *ComplexType) GetIsActive() bool + func (x *ComplexType) GetOneId() string + func (x *ComplexType) GetOtherId() int32 + func (x *ComplexType) ProtoReflect() protoreflect.Message + func (x *ComplexType) Reset() + func (x *ComplexType) String() string + type ComplexType_OneId struct + OneId string + type ComplexType_OtherId struct + OtherId int32 + type DemoSchema struct + BoolField bool + BytesField Bytes + DoubleField float64 + IntField int32 + StringField string + func DeserializeDemoSchema(r io.Reader) (DemoSchema, error) + func DeserializeDemoSchemaFromSchema(r io.Reader, schema string) (DemoSchema, error) + func NewDemoSchema() DemoSchema + func (_ DemoSchema) AppendArray() types.Field + func (_ DemoSchema) AppendMap(key string) types.Field + func (_ DemoSchema) AvroCRC64Fingerprint() []byte + func (_ DemoSchema) Finalize() + func (_ DemoSchema) HintSize(int) + func (_ DemoSchema) SetBoolean(v bool) + func (_ DemoSchema) SetBytes(v []byte) + func (_ DemoSchema) SetDouble(v float64) + func (_ DemoSchema) SetFloat(v float32) + func (_ DemoSchema) SetInt(v int32) + func (_ DemoSchema) SetLong(v int64) + func (_ DemoSchema) SetString(v string) + func (_ DemoSchema) SetUnionElem(v int64) + func (r *DemoSchema) Get(i int) types.Field + func (r *DemoSchema) NullField(i int) + func (r *DemoSchema) SetDefault(i int) + func (r *DemoSchema) UnmarshalJSON(data []byte) error + func (r DemoSchema) MarshalJSON() ([]byte, error) + func (r DemoSchema) Schema() string + func (r DemoSchema) SchemaName() string + func (r DemoSchema) Serialize(w io.Writer) error + type DependencyMessage struct + IsActive bool + TestMesssage *TestMessage + func (*DependencyMessage) Descriptor() ([]byte, []int) + func (*DependencyMessage) ProtoMessage() + func (x *DependencyMessage) GetIsActive() bool + func (x *DependencyMessage) GetTestMesssage() *TestMessage + func (x *DependencyMessage) ProtoReflect() protoreflect.Message + func (x *DependencyMessage) Reset() + func (x *DependencyMessage) String() string + type LinkedList struct + Next *LinkedList + Value int32 + func (*LinkedList) Descriptor() ([]byte, []int) + func (*LinkedList) ProtoMessage() + func (x *LinkedList) GetNext() *LinkedList + func (x *LinkedList) GetValue() int32 + func (x *LinkedList) ProtoReflect() protoreflect.Message + func (x *LinkedList) Reset() + func (x *LinkedList) String() string + type MessageId struct + Id string + func (*MessageId) Descriptor() ([]byte, []int) + func (*MessageId) ProtoMessage() + func (x *MessageId) GetId() string + func (x *MessageId) ProtoReflect() protoreflect.Message + func (x *MessageId) Reset() + func (x *MessageId) String() string + type NestedMessage struct + ComplexType *ComplexType + ExperimentsActive []string + Inner *NestedMessage_InnerMessage + IsActive bool + MapType map[string]string + Status Status + UpdatedAt *timestamppb.Timestamp + UserId *UserId + func (*NestedMessage) Descriptor() ([]byte, []int) + func (*NestedMessage) ProtoMessage() + func (x *NestedMessage) GetComplexType() *ComplexType + func (x *NestedMessage) GetExperimentsActive() []string + func (x *NestedMessage) GetInner() *NestedMessage_InnerMessage + func (x *NestedMessage) GetIsActive() bool + func (x *NestedMessage) GetMapType() map[string]string + func (x *NestedMessage) GetStatus() Status + func (x *NestedMessage) GetUpdatedAt() *timestamppb.Timestamp + func (x *NestedMessage) GetUserId() *UserId + func (x *NestedMessage) ProtoReflect() protoreflect.Message + func (x *NestedMessage) Reset() + func (x *NestedMessage) String() string + type NestedMessage_InnerEnum int32 + const NestedMessage_ALSO_ZERO + const NestedMessage_ZERO + func (NestedMessage_InnerEnum) Descriptor() protoreflect.EnumDescriptor + func (NestedMessage_InnerEnum) EnumDescriptor() ([]byte, []int) + func (NestedMessage_InnerEnum) Type() protoreflect.EnumType + func (x NestedMessage_InnerEnum) Enum() *NestedMessage_InnerEnum + func (x NestedMessage_InnerEnum) Number() protoreflect.EnumNumber + func (x NestedMessage_InnerEnum) String() string + type NestedMessage_InnerMessage struct + Id string + Ids []int32 + func (*NestedMessage_InnerMessage) Descriptor() ([]byte, []int) + func (*NestedMessage_InnerMessage) ProtoMessage() + func (x *NestedMessage_InnerMessage) GetId() string + func (x *NestedMessage_InnerMessage) GetIds() []int32 + func (x *NestedMessage_InnerMessage) ProtoReflect() protoreflect.Message + func (x *NestedMessage_InnerMessage) Reset() + func (x *NestedMessage_InnerMessage) String() string + type NestedRecord struct + BoolField bool + BytesField Bytes + StringField string + func DeserializeNestedRecord(r io.Reader) (NestedRecord, error) + func DeserializeNestedRecordFromSchema(r io.Reader, schema string) (NestedRecord, error) + func NewNestedRecord() NestedRecord + func (_ NestedRecord) AppendArray() types.Field + func (_ NestedRecord) AppendMap(key string) types.Field + func (_ NestedRecord) AvroCRC64Fingerprint() []byte + func (_ NestedRecord) Finalize() + func (_ NestedRecord) HintSize(int) + func (_ NestedRecord) SetBoolean(v bool) + func (_ NestedRecord) SetBytes(v []byte) + func (_ NestedRecord) SetDouble(v float64) + func (_ NestedRecord) SetFloat(v float32) + func (_ NestedRecord) SetInt(v int32) + func (_ NestedRecord) SetLong(v int64) + func (_ NestedRecord) SetString(v string) + func (_ NestedRecord) SetUnionElem(v int64) + func (r *NestedRecord) Get(i int) types.Field + func (r *NestedRecord) NullField(i int) + func (r *NestedRecord) SetDefault(i int) + func (r *NestedRecord) UnmarshalJSON(data []byte) error + func (r NestedRecord) MarshalJSON() ([]byte, error) + func (r NestedRecord) Schema() string + func (r NestedRecord) SchemaName() string + func (r NestedRecord) Serialize(w io.Writer) error + type NestedTestRecord struct + NumberField NumberRecord + OtherField NestedRecord + func DeserializeNestedTestRecord(r io.Reader) (NestedTestRecord, error) + func DeserializeNestedTestRecordFromSchema(r io.Reader, schema string) (NestedTestRecord, error) + func NewNestedTestRecord() NestedTestRecord + func (_ NestedTestRecord) AppendArray() types.Field + func (_ NestedTestRecord) AppendMap(key string) types.Field + func (_ NestedTestRecord) AvroCRC64Fingerprint() []byte + func (_ NestedTestRecord) Finalize() + func (_ NestedTestRecord) HintSize(int) + func (_ NestedTestRecord) SetBoolean(v bool) + func (_ NestedTestRecord) SetBytes(v []byte) + func (_ NestedTestRecord) SetDouble(v float64) + func (_ NestedTestRecord) SetFloat(v float32) + func (_ NestedTestRecord) SetInt(v int32) + func (_ NestedTestRecord) SetLong(v int64) + func (_ NestedTestRecord) SetString(v string) + func (_ NestedTestRecord) SetUnionElem(v int64) + func (r *NestedTestRecord) Get(i int) types.Field + func (r *NestedTestRecord) NullField(i int) + func (r *NestedTestRecord) SetDefault(i int) + func (r *NestedTestRecord) UnmarshalJSON(data []byte) error + func (r NestedTestRecord) MarshalJSON() ([]byte, error) + func (r NestedTestRecord) Schema() string + func (r NestedTestRecord) SchemaName() string + func (r NestedTestRecord) Serialize(w io.Writer) error + type NumberRecord struct + DoubleField float64 + FloatField float32 + IntField int32 + LongField int64 + func DeserializeNumberRecord(r io.Reader) (NumberRecord, error) + func DeserializeNumberRecordFromSchema(r io.Reader, schema string) (NumberRecord, error) + func NewNumberRecord() NumberRecord + func (_ NumberRecord) AppendArray() types.Field + func (_ NumberRecord) AppendMap(key string) types.Field + func (_ NumberRecord) AvroCRC64Fingerprint() []byte + func (_ NumberRecord) Finalize() + func (_ NumberRecord) HintSize(int) + func (_ NumberRecord) SetBoolean(v bool) + func (_ NumberRecord) SetBytes(v []byte) + func (_ NumberRecord) SetDouble(v float64) + func (_ NumberRecord) SetFloat(v float32) + func (_ NumberRecord) SetInt(v int32) + func (_ NumberRecord) SetLong(v int64) + func (_ NumberRecord) SetString(v string) + func (_ NumberRecord) SetUnionElem(v int64) + func (r *NumberRecord) Get(i int) types.Field + func (r *NumberRecord) NullField(i int) + func (r *NumberRecord) SetDefault(i int) + func (r *NumberRecord) UnmarshalJSON(data []byte) error + func (r NumberRecord) MarshalJSON() ([]byte, error) + func (r NumberRecord) Schema() string + func (r NumberRecord) SchemaName() string + func (r NumberRecord) Serialize(w io.Writer) error + type Pizza struct + Size string + Toppings []string + func (*Pizza) Descriptor() ([]byte, []int) + func (*Pizza) ProtoMessage() + func (x *Pizza) GetSize() string + func (x *Pizza) GetToppings() []string + func (x *Pizza) ProtoReflect() protoreflect.Message + func (x *Pizza) Reset() + func (x *Pizza) String() string + type RecursiveUnionTestRecord struct + RecursiveField *UnionNullRecursiveUnionTestRecord + func DeserializeRecursiveUnionTestRecord(r io.Reader) (RecursiveUnionTestRecord, error) + func DeserializeRecursiveUnionTestRecordFromSchema(r io.Reader, schema string) (RecursiveUnionTestRecord, error) + func NewRecursiveUnionTestRecord() RecursiveUnionTestRecord + func (_ RecursiveUnionTestRecord) AppendArray() types.Field + func (_ RecursiveUnionTestRecord) AppendMap(key string) types.Field + func (_ RecursiveUnionTestRecord) AvroCRC64Fingerprint() []byte + func (_ RecursiveUnionTestRecord) Finalize() + func (_ RecursiveUnionTestRecord) HintSize(int) + func (_ RecursiveUnionTestRecord) SetBoolean(v bool) + func (_ RecursiveUnionTestRecord) SetBytes(v []byte) + func (_ RecursiveUnionTestRecord) SetDouble(v float64) + func (_ RecursiveUnionTestRecord) SetFloat(v float32) + func (_ RecursiveUnionTestRecord) SetInt(v int32) + func (_ RecursiveUnionTestRecord) SetLong(v int64) + func (_ RecursiveUnionTestRecord) SetString(v string) + func (_ RecursiveUnionTestRecord) SetUnionElem(v int64) + func (r *RecursiveUnionTestRecord) Get(i int) types.Field + func (r *RecursiveUnionTestRecord) NullField(i int) + func (r *RecursiveUnionTestRecord) SetDefault(i int) + func (r *RecursiveUnionTestRecord) UnmarshalJSON(data []byte) error + func (r RecursiveUnionTestRecord) MarshalJSON() ([]byte, error) + func (r RecursiveUnionTestRecord) Schema() string + func (r RecursiveUnionTestRecord) SchemaName() string + func (r RecursiveUnionTestRecord) Serialize(w io.Writer) error + type Status int32 + const Status_ACTIVE + const Status_INACTIVE + func (Status) Descriptor() protoreflect.EnumDescriptor + func (Status) EnumDescriptor() ([]byte, []int) + func (Status) Type() protoreflect.EnumType + func (x Status) Enum() *Status + func (x Status) Number() protoreflect.EnumNumber + func (x Status) String() string + type TestMessage struct + TestBool bool + TestBytes []byte + TestDouble float64 + TestFixed32 uint32 + TestFixed64 uint64 + TestFloat float32 + TestInt32 int32 + TestInt64 int64 + TestSfixed32 int32 + TestSfixed64 int64 + TestSint32 int32 + TestSint64 int64 + TestString string + TestUint32 uint32 + TestUint64 uint64 + func (*TestMessage) Descriptor() ([]byte, []int) + func (*TestMessage) ProtoMessage() + func (x *TestMessage) GetTestBool() bool + func (x *TestMessage) GetTestBytes() []byte + func (x *TestMessage) GetTestDouble() float64 + func (x *TestMessage) GetTestFixed32() uint32 + func (x *TestMessage) GetTestFixed64() uint64 + func (x *TestMessage) GetTestFloat() float32 + func (x *TestMessage) GetTestInt32() int32 + func (x *TestMessage) GetTestInt64() int64 + func (x *TestMessage) GetTestSfixed32() int32 + func (x *TestMessage) GetTestSfixed64() int64 + func (x *TestMessage) GetTestSint32() int32 + func (x *TestMessage) GetTestSint64() int64 + func (x *TestMessage) GetTestString() string + func (x *TestMessage) GetTestUint32() uint32 + func (x *TestMessage) GetTestUint64() uint64 + func (x *TestMessage) ProtoReflect() protoreflect.Message + func (x *TestMessage) Reset() + func (x *TestMessage) String() string + type UnionNullRecursiveUnionTestRecord struct + Null *types.NullVal + RecursiveUnionTestRecord RecursiveUnionTestRecord + UnionType UnionNullRecursiveUnionTestRecordTypeEnum + func DeserializeUnionNullRecursiveUnionTestRecord(r io.Reader) (*UnionNullRecursiveUnionTestRecord, error) + func DeserializeUnionNullRecursiveUnionTestRecordFromSchema(r io.Reader, schema string) (*UnionNullRecursiveUnionTestRecord, error) + func NewUnionNullRecursiveUnionTestRecord() *UnionNullRecursiveUnionTestRecord + func (_ *UnionNullRecursiveUnionTestRecord) AppendArray() types.Field + func (_ *UnionNullRecursiveUnionTestRecord) AppendMap(key string) types.Field + func (_ *UnionNullRecursiveUnionTestRecord) Finalize() + func (_ *UnionNullRecursiveUnionTestRecord) HintSize(i int) + func (_ *UnionNullRecursiveUnionTestRecord) NullField(i int) + func (_ *UnionNullRecursiveUnionTestRecord) SetBoolean(v bool) + func (_ *UnionNullRecursiveUnionTestRecord) SetBytes(v []byte) + func (_ *UnionNullRecursiveUnionTestRecord) SetDefault(i int) + func (_ *UnionNullRecursiveUnionTestRecord) SetDouble(v float64) + func (_ *UnionNullRecursiveUnionTestRecord) SetFloat(v float32) + func (_ *UnionNullRecursiveUnionTestRecord) SetInt(v int32) + func (_ *UnionNullRecursiveUnionTestRecord) SetString(v string) + func (r *UnionNullRecursiveUnionTestRecord) Get(i int) types.Field + func (r *UnionNullRecursiveUnionTestRecord) MarshalJSON() ([]byte, error) + func (r *UnionNullRecursiveUnionTestRecord) Schema() string + func (r *UnionNullRecursiveUnionTestRecord) Serialize(w io.Writer) error + func (r *UnionNullRecursiveUnionTestRecord) SetLong(v int64) + func (r *UnionNullRecursiveUnionTestRecord) UnmarshalJSON(data []byte) error + type UnionNullRecursiveUnionTestRecordTypeEnum int + const UnionNullRecursiveUnionTestRecordTypeEnumRecursiveUnionTestRecord + type UserId struct + UserId isUserId_UserId + func (*UserId) Descriptor() ([]byte, []int) + func (*UserId) ProtoMessage() + func (m *UserId) GetUserId() isUserId_UserId + func (x *UserId) GetAnotherId() *MessageId + func (x *UserId) GetKafkaUserId() string + func (x *UserId) GetOtherUserId() int32 + func (x *UserId) ProtoReflect() protoreflect.Message + func (x *UserId) Reset() + func (x *UserId) String() string + type UserId_AnotherId struct + AnotherId *MessageId + type UserId_KafkaUserId struct + KafkaUserId string + type UserId_OtherUserId struct + OtherUserId int32