command

type ChangePassword struct {
	UserID          iggcon.Identifier `json:"-"`
	CurrentPassword string            `json:"CurrentPassword"`
	NewPassword     string            `json:"NewPassword"`
}

type Code int

type Command interface {
	// Code returns the command code associated with this command.
	Code() Code

	encoding.BinaryMarshaler
}

type CreateConsumerGroup struct {
	TopicPath
	Name string
}

type CreatePartitions struct {
	StreamId        iggcon.Identifier `json:"streamId"`
	TopicId         iggcon.Identifier `json:"topicId"`
	PartitionsCount uint32            `json:"partitionsCount"`
}

type CreatePersonalAccessToken struct {
	Name   string `json:"Name"`
	Expiry uint32 `json:"Expiry"`
}

type CreateStream struct {
	Name string
}

type CreateTopic 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"`
}

type CreateUser struct {
	Username    string              `json:"username"`
	Password    string              `json:"Password"`
	Status      iggcon.UserStatus   `json:"Status"`
	Permissions *iggcon.Permissions `json:"Permissions,omitempty"`
}

type DeleteConsumerGroup struct {
	TopicPath
	GroupId iggcon.Identifier
}

type DeleteConsumerOffset struct {
	Consumer    iggcon.Consumer
	StreamId    iggcon.Identifier
	TopicId     iggcon.Identifier
	PartitionId *uint32
}

type DeletePartitions struct {
	StreamId        iggcon.Identifier `json:"streamId"`
	TopicId         iggcon.Identifier `json:"topicId"`
	PartitionsCount uint32            `json:"partitionsCount"`
}

type DeletePersonalAccessToken struct {
	Name string `json:"Name"`
}

type DeleteStream struct {
	StreamId iggcon.Identifier
}

type DeleteTopic struct {
	StreamId iggcon.Identifier
	TopicId  iggcon.Identifier
}

type DeleteUser struct {
	Id iggcon.Identifier
}

type GetClient struct {
	ClientID uint32
}

type GetClients struct{}

type GetClusterMetadata struct {
}

type GetConsumerGroup struct {
	TopicPath
	GroupId iggcon.Identifier
}

type GetConsumerGroups struct {
	StreamId iggcon.Identifier
	TopicId  iggcon.Identifier
}

type GetConsumerOffset struct {
	StreamId    iggcon.Identifier `json:"streamId"`
	TopicId     iggcon.Identifier `json:"topicId"`
	Consumer    iggcon.Consumer   `json:"consumer"`
	PartitionId *uint32           `json:"partitionId"`
}

type GetPersonalAccessTokens struct{}

type GetStats struct{}

type GetStream struct {
	StreamId iggcon.Identifier
}

type GetStreams struct{}

type GetTopic struct {
	StreamId iggcon.Identifier
	TopicId  iggcon.Identifier
}

type GetTopics struct {
	StreamId iggcon.Identifier
}

type GetUser struct {
	Id iggcon.Identifier
}

type GetUsers struct{}

type JoinConsumerGroup struct {
	TopicPath
	GroupId iggcon.Identifier
}

type LeaveConsumerGroup struct {
	TopicPath
	GroupId iggcon.Identifier
}

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

type LoginWithPersonalAccessToken struct {
	Token string `json:"token"`
}

type LogoutUser struct{}

type Ping struct{}

type PollMessages 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"`
}

type SendMessages struct {
	Compression iggcon.IggyMessageCompression

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

type StoreConsumerOffsetRequest struct {
	StreamId    iggcon.Identifier `json:"streamId"`
	TopicId     iggcon.Identifier `json:"topicId"`
	Consumer    iggcon.Consumer   `json:"consumer"`
	PartitionId *uint32           `json:"partitionId"`
	Offset      uint64            `json:"offset"`
}

type TopicPath struct {
	StreamId iggcon.Identifier
	TopicId  iggcon.Identifier
}

type UpdatePermissions struct {
	UserID      iggcon.Identifier   `json:"-"`
	Permissions *iggcon.Permissions `json:"Permissions,omitempty"`
}

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

type UpdateTopic 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"`
}

type UpdateUser struct {
	UserID   iggcon.Identifier  `json:"-"`
	Username *string            `json:"username"`
	Status   *iggcon.UserStatus `json:"userStatus"`
}