topicproduceresponse

Documentation

Overview

Copyright (c) 2023 Cisco and/or its affiliates. All rights reserved.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

     https://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.

Index

• func PartitionProduceResponseHighestSupportedFlexVersion() int16
• func PartitionProduceResponseHighestSupportedVersion() int16
• func PartitionProduceResponseLowestSupportedFlexVersion() int16
• func PartitionProduceResponseLowestSupportedVersion() int16
• type PartitionProduceResponse
  • func PartitionProduceResponseDefault() PartitionProduceResponse
  • func (o *PartitionProduceResponse) BaseOffset() int64
  • func (o *PartitionProduceResponse) Clear()
  • func (o *PartitionProduceResponse) Equal(that *PartitionProduceResponse) bool
  • func (o *PartitionProduceResponse) ErrorCode() int16
  • func (o *PartitionProduceResponse) ErrorMessage() fields.NullableString
  • func (o *PartitionProduceResponse) Index() int32
  • func (o *PartitionProduceResponse) IsNil() bool
  • func (o *PartitionProduceResponse) LogAppendTimeMs() int64
  • func (o *PartitionProduceResponse) LogStartOffset() int64
  • func (o *PartitionProduceResponse) MarshalJSON() ([]byte, error)
  • func (o *PartitionProduceResponse) Read(buf *bytes.Reader, version int16) error
  • func (o *PartitionProduceResponse) RecordErrors() []partitionproduceresponse.BatchIndexAndErrorMessage
  • func (o *PartitionProduceResponse) Release()
  • func (o *PartitionProduceResponse) SetBaseOffset(val int64)
  • func (o *PartitionProduceResponse) SetDefault()
  • func (o *PartitionProduceResponse) SetErrorCode(val int16)
  • func (o *PartitionProduceResponse) SetErrorMessage(val fields.NullableString)
  • func (o *PartitionProduceResponse) SetIndex(val int32)
  • func (o *PartitionProduceResponse) SetLogAppendTimeMs(val int64)
  • func (o *PartitionProduceResponse) SetLogStartOffset(val int64)
  • func (o *PartitionProduceResponse) SetRecordErrors(val []partitionproduceresponse.BatchIndexAndErrorMessage)
  • func (o *PartitionProduceResponse) SetUnknownTaggedFields(val []fields.RawTaggedField)
  • func (o *PartitionProduceResponse) SizeInBytes(version int16) (int, error)
  • func (o *PartitionProduceResponse) String() string
  • func (o *PartitionProduceResponse) UnknownTaggedFields() []fields.RawTaggedField
  • func (o *PartitionProduceResponse) Write(buf *typesbytes.SliceWriter, version int16) error

Functions

func PartitionProduceResponseHighestSupportedFlexVersion

func PartitionProduceResponseHighestSupportedFlexVersion() int16

func PartitionProduceResponseHighestSupportedVersion

func PartitionProduceResponseHighestSupportedVersion() int16

func PartitionProduceResponseLowestSupportedFlexVersion

func PartitionProduceResponseLowestSupportedFlexVersion() int16

func PartitionProduceResponseLowestSupportedVersion

func PartitionProduceResponseLowestSupportedVersion() int16

Types

type PartitionProduceResponse

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

func PartitionProduceResponseDefault

func PartitionProduceResponseDefault() PartitionProduceResponse

func (*PartitionProduceResponse) BaseOffset

func (o *PartitionProduceResponse) BaseOffset() int64

func (*PartitionProduceResponse) Clear

func (o *PartitionProduceResponse) Clear()

func (*PartitionProduceResponse) Equal

func (o *PartitionProduceResponse) Equal(that *PartitionProduceResponse) bool

func (*PartitionProduceResponse) ErrorCode

func (o *PartitionProduceResponse) ErrorCode() int16

func (*PartitionProduceResponse) ErrorMessage

func (o *PartitionProduceResponse) ErrorMessage() fields.NullableString

func (*PartitionProduceResponse) Index

func (o *PartitionProduceResponse) Index() int32

func (*PartitionProduceResponse) IsNil

func (o *PartitionProduceResponse) IsNil() bool

func (*PartitionProduceResponse) LogAppendTimeMs

func (o *PartitionProduceResponse) LogAppendTimeMs() int64

func (*PartitionProduceResponse) LogStartOffset

func (o *PartitionProduceResponse) LogStartOffset() int64

func (*PartitionProduceResponse) MarshalJSON

func (o *PartitionProduceResponse) MarshalJSON() ([]byte, error)

func (*PartitionProduceResponse) Read

func (o *PartitionProduceResponse) Read(buf *bytes.Reader, version int16) error

func (*PartitionProduceResponse) RecordErrors

func (o *PartitionProduceResponse) RecordErrors() []partitionproduceresponse.BatchIndexAndErrorMessage

func (*PartitionProduceResponse) Release

func (o *PartitionProduceResponse) Release()

Release releases the dynamically allocated fields of this object by returning then to object pools

func (*PartitionProduceResponse) SetBaseOffset

func (o *PartitionProduceResponse) SetBaseOffset(val int64)

func (*PartitionProduceResponse) SetDefault

func (o *PartitionProduceResponse) SetDefault()

func (*PartitionProduceResponse) SetErrorCode

func (o *PartitionProduceResponse) SetErrorCode(val int16)

func (*PartitionProduceResponse) SetErrorMessage

func (o *PartitionProduceResponse) SetErrorMessage(val fields.NullableString)

func (*PartitionProduceResponse) SetIndex

func (o *PartitionProduceResponse) SetIndex(val int32)

func (*PartitionProduceResponse) SetLogAppendTimeMs

func (o *PartitionProduceResponse) SetLogAppendTimeMs(val int64)

func (*PartitionProduceResponse) SetLogStartOffset

func (o *PartitionProduceResponse) SetLogStartOffset(val int64)

func (*PartitionProduceResponse) SetRecordErrors

func (o *PartitionProduceResponse) SetRecordErrors(val []partitionproduceresponse.BatchIndexAndErrorMessage)

func (*PartitionProduceResponse) SetUnknownTaggedFields

func (o *PartitionProduceResponse) SetUnknownTaggedFields(val []fields.RawTaggedField)

func (*PartitionProduceResponse) SizeInBytes

func (o *PartitionProduceResponse) SizeInBytes(version int16) (int, error)

SizeInBytes returns the size of this data structure in bytes when it's serialized

func (*PartitionProduceResponse) String

func (o *PartitionProduceResponse) String() string

func (*PartitionProduceResponse) UnknownTaggedFields

func (o *PartitionProduceResponse) UnknownTaggedFields() []fields.RawTaggedField

func (*PartitionProduceResponse) Write

func (o *PartitionProduceResponse) Write(buf *typesbytes.SliceWriter, version int16) error