message_stream.go

package iggy

import . "github.com/iggy-rs/iggy-go-client/contracts"

type MessageStream interface {
	GetStreamById(request GetStreamRequest) (*StreamResponse, error)
	GetStreams() ([]StreamResponse, error)
	CreateStream(request CreateStreamRequest) error
	UpdateStream(request UpdateStreamRequest) error
	DeleteStream(id Identifier) error

	GetTopicById(streamId, topicId Identifier) (*TopicResponse, error)
	GetTopics(streamId Identifier) ([]TopicResponse, error)
	CreateTopic(request CreateTopicRequest) error
	UpdateTopic(request UpdateTopicRequest) error
	DeleteTopic(streamId, topicId Identifier) error

	SendMessages(request SendMessagesRequest) error
	PollMessages(request FetchMessagesRequest) (*FetchMessagesResponse, error)

	StoreOffset(request StoreOffsetRequest) error
	GetOffset(request GetOffsetRequest) (*OffsetResponse, error)

	GetConsumerGroups(streamId Identifier, topicId Identifier) ([]ConsumerGroupResponse, error)
	GetConsumerGroupById(streamId, topicId, groupId Identifier) (*ConsumerGroupResponse, error)
	CreateConsumerGroup(request CreateConsumerGroupRequest) error
	DeleteConsumerGroup(request DeleteConsumerGroupRequest) error
	JoinConsumerGroup(request JoinConsumerGroupRequest) error
	LeaveConsumerGroup(request LeaveConsumerGroupRequest) error

	CreatePartition(request CreatePartitionsRequest) error
	DeletePartition(request DeletePartitionRequest) error

	GetUser(identifier Identifier) (*UserResponse, error)
	GetUsers() ([]*UserResponse, error)
	CreateUser(request CreateUserRequest) error
	UpdateUser(request UpdateUserRequest) error
	UpdateUserPermissions(request UpdateUserPermissionsRequest) error
	ChangePassword(request ChangePasswordRequest) error
	DeleteUser(identifier Identifier) error

	CreateAccessToken(request CreateAccessTokenRequest) (*AccessToken, error)
	DeleteAccessToken(request DeleteAccessTokenRequest) error
	GetAccessTokens() ([]AccessTokenResponse, error)

	LogIn(request LogInRequest) (*LogInResponse, error)
	LogInWithAccessToken(request LogInAccessTokenRequest) (*LogInResponse, error)
	LogOut() error

	GetStats() (*Stats, error)
	Ping() error

	GetClients() ([]ClientResponse, error)
	GetClientById(clientId int) (*ClientResponse, error)
}