Documentation
¶
Index ¶
- 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, error)
- func DeserializeStreams(payload []byte) []iggcon.Stream
- func DeserializeToConsumerGroup(payload []byte, position int) (*iggcon.ConsumerGroup, int)
- func DeserializeToConsumerGroupMember(payload []byte, position int) (iggcon.ConsumerGroupMember, 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 MapClientInfo(payload []byte, position int) (iggcon.ClientInfo, int)
- type TcpStats
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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, error)
func DeserializeStreams ¶
func DeserializeToConsumerGroup ¶
func DeserializeToConsumerGroup(payload []byte, position int) (*iggcon.ConsumerGroup, int)
func DeserializeToConsumerGroupMember ¶ added in v0.6.0
func DeserializeToConsumerGroupMember(payload []byte, position int) (iggcon.ConsumerGroupMember, int)
func DeserializeToStream ¶
func DeserializeToTopic ¶
func DeserializeTopic ¶
func DeserializeTopic(payload []byte) (*iggcon.TopicDetails, error)
func DeserializeUser ¶
func DeserializeUser(payload []byte) (*iggcon.UserInfoDetails, error)
func MapClientInfo ¶
func MapClientInfo(payload []byte, position int) (iggcon.ClientInfo, int)
Types ¶
Source Files
Click to show internal directories.
Click to hide internal directories.