superstream

type Client struct {
	ClientID              int
	AccountName           string
	NatsConnectionID      string
	IsConsumer            bool
	IsProducer            bool
	LearningFactor        int
	LearningFactorCounter int
	LearningRequestSent   bool
	GetSchemaRequestSent  bool
	ProducerProtoDesc     protoreflect.MessageDescriptor
	ProducerSchemaID      string
	ConsumerProtoDescMap  map[string]protoreflect.MessageDescriptor
	Counters              ClientCounters
	Config                ClientConfig
}

type ClientConfig struct {
	ClientType                                string             `json:"client_type"`
	ProducerMaxMessageBytes                   int                `json:"producer_max_messages_bytes"`
	ProducerRequiredAcks                      string             `json:"producer_required_acks"`
	ProducerTimeout                           time.Duration      `json:"producer_timeout"`
	ProducerRetryMax                          int                `json:"producer_retry_max"`
	ProducerRetryBackoff                      time.Duration      `json:"producer_retry_backoff"`
	ProducerReturnErrors                      bool               `json:"producer_return_errors"`
	ProducerReturnSuccesses                   bool               `json:"producer_return_successes"`
	ProducerFlushMaxMessages                  int                `json:"producer_flush_max_messages"`
	ProducerCompressionLevel                  string             `json:"producer_compression_level"`
	ConsumerFetchMin                          int32              `json:"consumer_fetch_min"`
	ConsumerFetchDefault                      int32              `json:"consumer_fetch_default"`
	ConsumerRetryBackOff                      time.Duration      `json:"consumer_retry_backoff"`
	ConsumerMaxWaitTime                       time.Duration      `json:"consumer_max_wait_time"`
	ConsumerMaxProcessingTime                 time.Duration      `json:"consumer_mex_processing_time"`
	ConsumerReturnErrors                      bool               `json:"consumer_return_errors"`
	ConsumerOffsetAutoCommitEnable            bool               `json:"consumer_offset_auto_commit_enable"`
	ConsumerOffsetAutoCommintInterval         time.Duration      `json:"consumer_offset_auto_commit_interval"`
	ConsumerOffsetsInitial                    int                `json:"consumer_offsets_initial"`
	ConsumerOffsetsRetryMax                   int                `json:"consumer_offsets_retry_max"`
	ConsumerGroupSessionTimeout               time.Duration      `json:"consumer_group_session_timeout"`
	ConsumerGroupHeartBeatInterval            time.Duration      `json:"consumer_group_heart_beat_interval"`
	ConsumerGroupRebalanceTimeout             time.Duration      `json:"consumer_group_rebalance_timeout"`
	ConsumerGroupRebalanceRetryMax            int                `json:"consumer_group_rebalance_retry_max"`
	ConsumerGroupRebalanceRetryBackOff        time.Duration      `json:"consumer_group_rebalance_retry_back_off"`
	ConsumerGroupRebalanceResetInvalidOffsets bool               `json:"consumer_group_rebalance_reset_invalid_offsets"`
	ConsumerGroupId                           string             `json:"consumer_group_id"`
	Servers                                   string             `json:"servers"`
	ProducerTopicsPartitions                  map[string][]int32 `json:"producer_topics_partitions"`
	ConsumerTopicsPartitions                  map[string][]int32 `json:"consumer_group_topics_partitions"`
}

type ClientCounters struct {
	TotalBytesBeforeReduction         int64 `json:"total_bytes_before_reduction"`
	TotalBytesAfterReduction          int64 `json:"total_bytes_after_reduction"`
	TotalMessagesSuccessfullyProduce  int   `json:"total_messages_successfully_produce"`
	TotalMessagesSuccessfullyConsumed int   `json:"total_messages_successfully_consumed"`
	TotalMessagesFailedProduce        int   `json:"total_messages_failed_produce"`
	TotalMessagesFailedConsume        int   `json:"total_messages_failed_consume"`
}

type ClientReconnectionUpdateReq struct {
	NewNatsConnectionID string `json:"new_nats_connection_id"`
	ClientID            int    `json:"client_id"`
}

type ClientTypeUpdateReq struct {
	ClientID int    `json:"client_id"`
	Type     string `json:"type"`
}

type ClientUpdateSub struct {
	ClientID     int
	Subscription *nats.Subscription
	UpdateCahn   chan Update
}

type GetSchemaReq struct {
	SchemaID string `json:"schema_id"`
}

type Option func(*Options) error

type Options struct {
	Host           string
	LearningFactor int
	ConsumerGroup  string
	Servers        string
}

type RegisterReq struct {
	NatsConnectionID string       `json:"nats_connection_id"`
	Language         string       `json:"language"`
	Version          string       `json:"version"`
	LearningFactor   int          `json:"learning_factor"`
	Config           ClientConfig `json:"config"`
}

type RegisterResp struct {
	ClientID       int    `json:"client_id"`
	AccountName    string `json:"account_name"`
	LearningFactor int    `json:"learning_factor"`
}

type SaramaConsumerInterceptor struct {
	Client *Client
}

type SaramaProducerInterceptor struct {
	Client *Client
}

type SchemaUpdateReq struct {
	MasterMsgName string `json:"master_msg_name"`
	FileName      string `json:"file_name"`
	SchemaID      string `json:"schema_id"`
	Desc          []byte `json:"desc"`
}

type TopicsPartitionsPerProducerConsumer struct {
	ProducerTopicsPartitions map[string][]int32 `json:"producer_topics_partitions"`
	ConsumerTopicsPartitions map[string][]int32 `json:"consumer_group_topics_partitions"`
}

type Update struct {
	Type    string
	Payload []byte
}