Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

binaryserialization

package

Go to main page

Versions in this module

v0

v0.8.0

Apr 14, 2026

v0.7.1-edge.1

Mar 5, 2026

v0.7.0

Feb 17, 2026

v0.6.1-edge.1

Feb 6, 2026

v0.6.0

Dec 2, 2025

Changes in this version

+ func DeleteOffset(request iggcon.DeleteConsumerOffsetRequest) []byte

+ func DeserializeToConsumerGroupMember(payload []byte, position int) (iggcon.ConsumerGroupMember, int)

+ func SerializeConsumer(consumer iggcon.Consumer) []byte

+ func SerializePartitioning(partitioning iggcon.Partitioning) []byte

v0.5.2-edge.1

Sep 2, 2025

v0.5.1-edge.1

Sep 1, 2025

v0.5.0

Aug 4, 2025

Changes in this version

+ func CalculatePermissionsSize(data *iggcon.Permissions) int

+ func CreateGroup(request iggcon.CreateConsumerGroupRequest) []byte

+ func CreatePartitions(request iggcon.CreatePartitionsRequest) []byte

+ func DeletePartitions(request iggcon.DeletePartitionsRequest) []byte

+ func DeserializeAccessToken(payload []byte) (*iggcon.RawPersonalAccessToken, error)

+ func DeserializeAccessTokens(payload []byte) ([]iggcon.PersonalAccessTokenInfo, error)

+ func DeserializeClient(payload []byte) *iggcon.ClientInfoDetails

+ func DeserializeClients(payload []byte) ([]iggcon.ClientInfo, error)

+ func DeserializeConsumerGroup(payload []byte) *iggcon.ConsumerGroupDetails

+ func DeserializeConsumerGroups(payload []byte) []iggcon.ConsumerGroup

+ func DeserializeFetchMessagesResponse(payload []byte, compression iggcon.IggyMessageCompression) (*iggcon.PolledMessage, error)

+ func DeserializeLogInResponse(payload []byte) *iggcon.IdentityInfo

+ func DeserializeOffset(payload []byte) *iggcon.ConsumerOffsetInfo

+ func DeserializePartition(payload []byte, position int) (iggcon.PartitionContract, int)

+ func DeserializeStream(payload []byte) *iggcon.StreamDetails

+ func DeserializeStreams(payload []byte) []iggcon.Stream

+ func DeserializeToConsumerGroup(payload []byte, position int) (*iggcon.ConsumerGroup, int)

+ func DeserializeToStream(payload []byte, position int) (iggcon.Stream, int)

+ func DeserializeToTopic(payload []byte, position int) (iggcon.Topic, int, error)

+ func DeserializeTopic(payload []byte) (*iggcon.TopicDetails, error)

+ func DeserializeTopics(payload []byte) ([]iggcon.Topic, error)

+ func DeserializeUser(payload []byte) (*iggcon.UserInfoDetails, error)

+ func DeserializeUsers(payload []byte) ([]iggcon.UserInfo, error)

+ func GetBytesFromPermissions(data *iggcon.Permissions) []byte

+ func GetOffset(request iggcon.GetConsumerOffsetRequest) []byte

+ func MapClientInfo(payload []byte, position int) (iggcon.ClientInfo, int)

+ func SerializeChangePasswordRequest(request iggcon.ChangePasswordRequest) []byte

+ func SerializeCreatePersonalAccessToken(request iggcon.CreatePersonalAccessTokenRequest) []byte

+ func SerializeCreateUserRequest(request iggcon.CreateUserRequest) []byte

+ func SerializeDeletePersonalAccessToken(request iggcon.DeletePersonalAccessTokenRequest) []byte

+ func SerializeIdentifier(identifier iggcon.Identifier) []byte

+ func SerializeIdentifiers(identifiers ...iggcon.Identifier) []byte

+ func SerializeLoginWithPersonalAccessToken(request iggcon.LoginWithPersonalAccessTokenRequest) []byte

+ func SerializeUint32(value uint32) []byte

+ func SerializeUpdateUser(request iggcon.UpdateUserRequest) []byte

+ func SerializeUpdateUserPermissionsRequest(request iggcon.UpdatePermissionsRequest) []byte

+ func UpdateOffset(request iggcon.StoreConsumerOffsetRequest) []byte

+ type TcpCreateStreamRequest struct

+ Name string

+ StreamId *uint32

+ func (request *TcpCreateStreamRequest) Serialize() []byte

+ type TcpCreateTopicRequest struct

+ CompressionAlgorithm iggcon.CompressionAlgorithm

+ MaxTopicSize uint64

+ MessageExpiry iggcon.Duration

+ Name string

+ PartitionsCount uint32

+ ReplicationFactor *uint8

+ StreamId iggcon.Identifier

+ TopicId *uint32

+ func (request *TcpCreateTopicRequest) Serialize() []byte

+ type TcpFetchMessagesRequest struct

+ AutoCommit bool

+ Consumer iggcon.Consumer

+ Count uint32

+ PartitionId *uint32

+ Strategy iggcon.PollingStrategy

+ StreamId iggcon.Identifier

+ TopicId iggcon.Identifier

+ func (request *TcpFetchMessagesRequest) Serialize() []byte

+ type TcpLogInRequest struct

+ Password string

+ Username string

+ func (request *TcpLogInRequest) Serialize() []byte

+ type TcpSendMessagesRequest struct

+ Messages []iggcon.IggyMessage

+ Partitioning iggcon.Partitioning

+ StreamId iggcon.Identifier

+ TopicId iggcon.Identifier

+ func (request *TcpSendMessagesRequest) Serialize(compression iggcon.IggyMessageCompression) []byte

+ type TcpStats struct

+ func (stats *TcpStats) Deserialize(payload []byte) error

+ type TcpUpdateStreamRequest struct

+ Name string

+ StreamId iggcon.Identifier

+ func (request *TcpUpdateStreamRequest) Serialize() []byte

+ type TcpUpdateTopicRequest struct

+ CompressionAlgorithm iggcon.CompressionAlgorithm

+ MaxTopicSize uint64

+ MessageExpiry iggcon.Duration

+ Name string

+ ReplicationFactor *uint8

+ StreamId iggcon.Identifier

+ TopicId iggcon.Identifier

+ func (request *TcpUpdateTopicRequest) Serialize() []byte

v0.5.0-edge.1

Jul 28, 2025