Versions in this module Expand all Collapse all v0 v0.8.0 Apr 14, 2026 Changes in this version + type ChangePassword struct + CurrentPassword string + NewPassword string + UserID iggcon.Identifier + func (c *ChangePassword) Code() Code + func (c *ChangePassword) MarshalBinary() ([]byte, error) + type Code int + const ChangePasswordCode + const CreateAccessTokenCode + const CreateGroupCode + const CreatePartitionsCode + const CreateStreamCode + const CreateTopicCode + const CreateUserCode + const DeleteAccessTokenCode + const DeleteConsumerOffsetCode + const DeleteGroupCode + const DeletePartitionsCode + const DeleteStreamCode + const DeleteTopicCode + const DeleteUserCode + const GetAccessTokensCode + const GetClientCode + const GetClientsCode + const GetClusterMetadataCode + const GetGroupCode + const GetGroupsCode + const GetMeCode + const GetOffsetCode + const GetSnapshotFileCode + const GetStatsCode + const GetStreamCode + const GetStreamsCode + const GetTopicCode + const GetTopicsCode + const GetUserCode + const GetUsersCode + const JoinGroupCode + const LeaveGroupCode + const LoginUserCode + const LoginWithAccessTokenCode + const LogoutUserCode + const PingCode + const PollMessagesCode + const SendMessagesCode + const StoreOffsetCode + const UpdatePermissionsCode + const UpdateStreamCode + const UpdateTopicCode + const UpdateUserCode + type Command interface + Code func() Code + type CreateConsumerGroup struct + Name string + func (c *CreateConsumerGroup) Code() Code + func (c *CreateConsumerGroup) MarshalBinary() ([]byte, error) + type CreatePartitions struct + PartitionsCount uint32 + StreamId iggcon.Identifier + TopicId iggcon.Identifier + func (c *CreatePartitions) Code() Code + func (c *CreatePartitions) MarshalBinary() ([]byte, error) + type CreatePersonalAccessToken struct + Expiry uint32 + Name string + func (c *CreatePersonalAccessToken) Code() Code + func (c *CreatePersonalAccessToken) MarshalBinary() ([]byte, error) + type CreateStream struct + Name string + func (request *CreateStream) Code() Code + func (request *CreateStream) MarshalBinary() ([]byte, error) + type CreateTopic struct + CompressionAlgorithm iggcon.CompressionAlgorithm + MaxTopicSize uint64 + MessageExpiry iggcon.Duration + Name string + PartitionsCount uint32 + ReplicationFactor *uint8 + StreamId iggcon.Identifier + func (t *CreateTopic) Code() Code + func (t *CreateTopic) MarshalBinary() ([]byte, error) + type CreateUser struct + Password string + Permissions *iggcon.Permissions + Status iggcon.UserStatus + Username string + func (c *CreateUser) Code() Code + func (c *CreateUser) MarshalBinary() ([]byte, error) + type DeleteConsumerGroup struct + GroupId iggcon.Identifier + func (d *DeleteConsumerGroup) Code() Code + func (d *DeleteConsumerGroup) MarshalBinary() ([]byte, error) + type DeleteConsumerOffset struct + Consumer iggcon.Consumer + PartitionId *uint32 + StreamId iggcon.Identifier + TopicId iggcon.Identifier + func (d *DeleteConsumerOffset) Code() Code + func (d *DeleteConsumerOffset) MarshalBinary() ([]byte, error) + type DeletePartitions struct + PartitionsCount uint32 + StreamId iggcon.Identifier + TopicId iggcon.Identifier + func (d *DeletePartitions) Code() Code + func (d *DeletePartitions) MarshalBinary() ([]byte, error) + type DeletePersonalAccessToken struct + Name string + func (d *DeletePersonalAccessToken) Code() Code + func (d *DeletePersonalAccessToken) MarshalBinary() ([]byte, error) + type DeleteStream struct + StreamId iggcon.Identifier + func (d *DeleteStream) Code() Code + func (d *DeleteStream) MarshalBinary() ([]byte, error) + type DeleteTopic struct + StreamId iggcon.Identifier + TopicId iggcon.Identifier + func (d *DeleteTopic) Code() Code + func (d *DeleteTopic) MarshalBinary() ([]byte, error) + type DeleteUser struct + Id iggcon.Identifier + func (d *DeleteUser) Code() Code + func (d *DeleteUser) MarshalBinary() ([]byte, error) + type GetClient struct + ClientID uint32 + func (c *GetClient) Code() Code + func (c *GetClient) MarshalBinary() ([]byte, error) + type GetClients struct + func (c *GetClients) Code() Code + func (c *GetClients) MarshalBinary() ([]byte, error) + type GetClusterMetadata struct + func (m *GetClusterMetadata) Code() Code + func (m *GetClusterMetadata) MarshalBinary() ([]byte, error) + type GetConsumerGroup struct + GroupId iggcon.Identifier + func (g *GetConsumerGroup) Code() Code + func (g *GetConsumerGroup) MarshalBinary() ([]byte, error) + type GetConsumerGroups struct + StreamId iggcon.Identifier + TopicId iggcon.Identifier + func (g *GetConsumerGroups) Code() Code + func (g *GetConsumerGroups) MarshalBinary() ([]byte, error) + type GetConsumerOffset struct + Consumer iggcon.Consumer + PartitionId *uint32 + StreamId iggcon.Identifier + TopicId iggcon.Identifier + func (g *GetConsumerOffset) Code() Code + func (g *GetConsumerOffset) MarshalBinary() ([]byte, error) + type GetPersonalAccessTokens struct + func (g *GetPersonalAccessTokens) Code() Code + func (g *GetPersonalAccessTokens) MarshalBinary() ([]byte, error) + type GetStats struct + func (c *GetStats) Code() Code + func (c *GetStats) MarshalBinary() ([]byte, error) + type GetStream struct + StreamId iggcon.Identifier + func (g *GetStream) Code() Code + func (g *GetStream) MarshalBinary() ([]byte, error) + type GetStreams struct + func (g *GetStreams) Code() Code + func (g *GetStreams) MarshalBinary() ([]byte, error) + type GetTopic struct + StreamId iggcon.Identifier + TopicId iggcon.Identifier + func (g *GetTopic) Code() Code + func (g *GetTopic) MarshalBinary() ([]byte, error) + type GetTopics struct + StreamId iggcon.Identifier + func (g *GetTopics) Code() Code + func (g *GetTopics) MarshalBinary() ([]byte, error) + type GetUser struct + Id iggcon.Identifier + func (c *GetUser) Code() Code + func (c *GetUser) MarshalBinary() ([]byte, error) + type GetUsers struct + func (g *GetUsers) Code() Code + func (g *GetUsers) MarshalBinary() ([]byte, error) + type JoinConsumerGroup struct + GroupId iggcon.Identifier + func (j *JoinConsumerGroup) Code() Code + func (j *JoinConsumerGroup) MarshalBinary() ([]byte, error) + type LeaveConsumerGroup struct + GroupId iggcon.Identifier + func (l *LeaveConsumerGroup) Code() Code + func (l *LeaveConsumerGroup) MarshalBinary() ([]byte, error) + type LoginUser struct + Password string + Username string + func (lu *LoginUser) Code() Code + func (lu *LoginUser) MarshalBinary() ([]byte, error) + type LoginWithPersonalAccessToken struct + Token string + func (lw *LoginWithPersonalAccessToken) Code() Code + func (lw *LoginWithPersonalAccessToken) MarshalBinary() ([]byte, error) + type LogoutUser struct + func (lu *LogoutUser) Code() Code + func (lu *LogoutUser) MarshalBinary() ([]byte, error) + type Ping struct + func (p *Ping) Code() Code + func (p *Ping) MarshalBinary() ([]byte, error) + type PollMessages struct + AutoCommit bool + Consumer iggcon.Consumer + Count uint32 + PartitionId *uint32 + Strategy iggcon.PollingStrategy + StreamId iggcon.Identifier + TopicId iggcon.Identifier + func (m *PollMessages) Code() Code + func (m *PollMessages) MarshalBinary() ([]byte, error) + type SendMessages struct + Compression iggcon.IggyMessageCompression + Messages []iggcon.IggyMessage + Partitioning iggcon.Partitioning + StreamId iggcon.Identifier + TopicId iggcon.Identifier + func (s *SendMessages) Code() Code + func (s *SendMessages) MarshalBinary() ([]byte, error) + type StoreConsumerOffsetRequest struct + Consumer iggcon.Consumer + Offset uint64 + PartitionId *uint32 + StreamId iggcon.Identifier + TopicId iggcon.Identifier + func (s *StoreConsumerOffsetRequest) Code() Code + func (s *StoreConsumerOffsetRequest) MarshalBinary() ([]byte, error) + type TopicPath struct + StreamId iggcon.Identifier + TopicId iggcon.Identifier + type UpdatePermissions struct + Permissions *iggcon.Permissions + UserID iggcon.Identifier + func (u *UpdatePermissions) Code() Code + func (u *UpdatePermissions) MarshalBinary() ([]byte, error) + type UpdateStream struct + Name string + StreamId iggcon.Identifier + func (u *UpdateStream) Code() Code + func (u *UpdateStream) MarshalBinary() ([]byte, error) + type UpdateTopic struct + CompressionAlgorithm iggcon.CompressionAlgorithm + MaxTopicSize uint64 + MessageExpiry iggcon.Duration + Name string + ReplicationFactor *uint8 + StreamId iggcon.Identifier + TopicId iggcon.Identifier + func (u *UpdateTopic) Code() Code + func (u *UpdateTopic) MarshalBinary() ([]byte, error) + type UpdateUser struct + Status *iggcon.UserStatus + UserID iggcon.Identifier + Username *string + func (u *UpdateUser) Code() Code + func (u *UpdateUser) MarshalBinary() ([]byte, error)
Go to main page