sg

type AsyncProducer struct {
	// contains filtered or unexported fields
}

type Client struct {
	// contains filtered or unexported fields
}

type Consumer struct {
	// contains filtered or unexported fields
}

type Handler interface {
	Consume(msg *sgproto.Message) error
}

type HandlerFunc func(msg *sgproto.Message) error

type Mux struct {
	// contains filtered or unexported fields
}

type MuxManager struct {
	Mux                  *Mux
	Client               *Client
	ConsumerGroup        string
	ConsumerName         string
	SynchronousCompution bool
	ReFetchSleepDuration time.Duration
	// contains filtered or unexported fields
}

type Producer interface {
	Produce(ctx context.Context, msg *ProducerMessage) error
	ProduceMessages(ctx context.Context, msgs []*ProducerMessage) error
	Close() error
}

type ProducerConfig struct {
	// contains filtered or unexported fields
}

type ProducerMessage struct {
	ConsumeIn time.Duration // TODO: waiting for server to handle this without manually setting an offset
	Value     []byte
}

type ProducerOption func(*ProducerConfig)

type SyncProducer struct {
	// contains filtered or unexported fields
}