binaryserialization

Documentation

Index

• 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
  • func (request *TcpCreateStreamRequest) Serialize() []byte
• type TcpCreateTopicRequest
  • func (request *TcpCreateTopicRequest) Serialize() []byte
• type TcpFetchMessagesRequest
  • func (request *TcpFetchMessagesRequest) Serialize() []byte
• type TcpLogInRequest
  • func (request *TcpLogInRequest) Serialize() []byte
• type TcpSendMessagesRequest
  • func (request *TcpSendMessagesRequest) Serialize(compression iggcon.IggyMessageCompression) []byte
• type TcpStats
  • func (stats *TcpStats) Deserialize(payload []byte) error
• type TcpUpdateStreamRequest
  • func (request *TcpUpdateStreamRequest) Serialize() []byte
• type TcpUpdateTopicRequest
  • func (request *TcpUpdateTopicRequest) Serialize() []byte

Functions

func CalculatePermissionsSize

func CalculatePermissionsSize(data *iggcon.Permissions) int

func CreateGroup

func CreateGroup(request iggcon.CreateConsumerGroupRequest) []byte

func CreatePartitions

func CreatePartitions(request iggcon.CreatePartitionsRequest) []byte

func DeletePartitions

func DeletePartitions(request iggcon.DeletePartitionsRequest) []byte

func DeserializeAccessToken

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

func DeserializeAccessTokens

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

func DeserializeClient

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

func DeserializeClients

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

func DeserializeConsumerGroup

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

func DeserializeConsumerGroups

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

func DeserializeFetchMessagesResponse

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

func DeserializeLogInResponse

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

func DeserializeOffset

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

func DeserializePartition

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

func DeserializeStream

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

func DeserializeStreams

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

func DeserializeToConsumerGroup

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

func DeserializeToStream

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

func DeserializeToTopic

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

func DeserializeTopic

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

func DeserializeTopics

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

func DeserializeUser

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

func DeserializeUsers

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

func GetBytesFromPermissions

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

func GetOffset

func GetOffset(request iggcon.GetConsumerOffsetRequest) []byte

func MapClientInfo

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

func SerializeChangePasswordRequest

func SerializeChangePasswordRequest(request iggcon.ChangePasswordRequest) []byte

func SerializeCreatePersonalAccessToken

func SerializeCreatePersonalAccessToken(request iggcon.CreatePersonalAccessTokenRequest) []byte

func SerializeCreateUserRequest

func SerializeCreateUserRequest(request iggcon.CreateUserRequest) []byte

func SerializeDeletePersonalAccessToken

func SerializeDeletePersonalAccessToken(request iggcon.DeletePersonalAccessTokenRequest) []byte

func SerializeIdentifier

func SerializeIdentifier(identifier iggcon.Identifier) []byte

func SerializeIdentifiers

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

func SerializeLoginWithPersonalAccessToken

func SerializeLoginWithPersonalAccessToken(request iggcon.LoginWithPersonalAccessTokenRequest) []byte

func SerializeUint32

func SerializeUint32(value uint32) []byte

func SerializeUpdateUser

func SerializeUpdateUser(request iggcon.UpdateUserRequest) []byte

func SerializeUpdateUserPermissionsRequest

func SerializeUpdateUserPermissionsRequest(request iggcon.UpdatePermissionsRequest) []byte

func UpdateOffset

func UpdateOffset(request iggcon.StoreConsumerOffsetRequest) []byte

Types

type TcpCreateStreamRequest

type TcpCreateStreamRequest struct {
	Name     string
	StreamId *uint32
}

func (*TcpCreateStreamRequest) Serialize

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

type TcpCreateTopicRequest

type TcpCreateTopicRequest struct {
	StreamId             iggcon.Identifier           `json:"streamId"`
	PartitionsCount      uint32                      `json:"partitionsCount"`
	CompressionAlgorithm iggcon.CompressionAlgorithm `json:"compressionAlgorithm"`
	MessageExpiry        iggcon.Duration             `json:"messageExpiry"`
	MaxTopicSize         uint64                      `json:"maxTopicSize"`
	Name                 string                      `json:"name"`
	ReplicationFactor    *uint8                      `json:"replicationFactor"`
	TopicId              *uint32                     `json:"topicId"`
}

func (*TcpCreateTopicRequest) Serialize

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

type TcpFetchMessagesRequest

type TcpFetchMessagesRequest struct {
	StreamId    iggcon.Identifier      `json:"streamId"`
	TopicId     iggcon.Identifier      `json:"topicId"`
	Consumer    iggcon.Consumer        `json:"consumer"`
	PartitionId *uint32                `json:"partitionId"`
	Strategy    iggcon.PollingStrategy `json:"pollingStrategy"`
	Count       uint32                 `json:"count"`
	AutoCommit  bool                   `json:"autoCommit"`
}

func (*TcpFetchMessagesRequest) Serialize

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

type TcpLogInRequest

type TcpLogInRequest struct {
	Username string `json:"username"`
	Password string `json:"password"`
}

func (*TcpLogInRequest) Serialize

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

type TcpSendMessagesRequest

type TcpSendMessagesRequest struct {
	StreamId     iggcon.Identifier    `json:"streamId"`
	TopicId      iggcon.Identifier    `json:"topicId"`
	Partitioning iggcon.Partitioning  `json:"partitioning"`
	Messages     []iggcon.IggyMessage `json:"messages"`
}

func (*TcpSendMessagesRequest) Serialize

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

type TcpStats

type TcpStats struct {
	iggcon.Stats
}

func (*TcpStats) Deserialize

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

type TcpUpdateStreamRequest

type TcpUpdateStreamRequest struct {
	StreamId iggcon.Identifier `json:"streamId"`
	Name     string            `json:"name"`
}

func (*TcpUpdateStreamRequest) Serialize

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

type TcpUpdateTopicRequest

type TcpUpdateTopicRequest struct {
	StreamId             iggcon.Identifier           `json:"streamId"`
	TopicId              iggcon.Identifier           `json:"topicId"`
	CompressionAlgorithm iggcon.CompressionAlgorithm `json:"compressionAlgorithm"`
	MessageExpiry        iggcon.Duration             `json:"messageExpiry"`
	MaxTopicSize         uint64                      `json:"maxTopicSize"`
	ReplicationFactor    *uint8                      `json:"replicationFactor"`
	Name                 string                      `json:"name"`
}

func (*TcpUpdateTopicRequest) Serialize

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