core

Documentation

Index

• type Builder
  • func NewBuilder() *Builder
  • func (b *Builder) Build() *Client
  • func (b *Builder) Region(region string) (client *Builder)
• type Client
  • func NewClient(param *param.Client) *Client
  • func (c *Client) Consumer() *ConsumerBuilder[any]
  • func (c *Client) Producer(topic string) *ProducerBuilder[any]
• type Consumer
  • func NewConsumer[T any](param *param.Consumer[T], get callback.GetClient) *Consumer[T]
  • func (c *Consumer[T]) Handle() *builder.Handle[T]
• type ConsumerBuilder
  • func NewConsumerBuilder[T any](get callback.GetClient) *ConsumerBuilder[T]
  • func (c *ConsumerBuilder[T]) Build() *Consumer[T]
• type Producer
  • func NewProducer[T any](get callback.GetClient, param *param.Producer[T]) *Producer[T]
  • func (p *Producer[T]) Send() *builder.Send[T]
• type ProducerBuilder
  • func NewProducerBuilder[T any](topic string) (producer *ProducerBuilder[T])
  • func (p *ProducerBuilder[T]) Build() *Producer[T]

Types

type Builder

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

func NewBuilder

func NewBuilder() *Builder

func (*Builder) Build

func (b *Builder) Build() *Client

func (*Builder) Region

func (b *Builder) Region(region string) (client *Builder)

type Client

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

func NewClient

func NewClient(param *param.Client) *Client

func (*Client) Consumer

func (c *Client) Consumer() *ConsumerBuilder[any]

func (*Client) Producer

func (c *Client) Producer(topic string) *ProducerBuilder[any]

type Consumer

type Consumer[T any] struct {
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer[T any](param *param.Consumer[T], get callback.GetClient) *Consumer[T]

func (*Consumer[T]) Handle

func (c *Consumer[T]) Handle() *builder.Handle[T]

type ConsumerBuilder

type ConsumerBuilder[T any] struct {
	*builder.Connection
	*internal.Base[T]
	// contains filtered or unexported fields
}

func NewConsumerBuilder

func NewConsumerBuilder[T any](get callback.GetClient) *ConsumerBuilder[T]

func (*ConsumerBuilder[T]) Build

func (c *ConsumerBuilder[T]) Build() *Consumer[T]

type Producer

type Producer[T any] struct {
	// contains filtered or unexported fields
}

func NewProducer

func NewProducer[T any](get callback.GetClient, param *param.Producer[T]) *Producer[T]

func (*Producer[T]) Send

func (p *Producer[T]) Send() *builder.Send[T]

type ProducerBuilder

type ProducerBuilder[T any] struct {
	*builder.Connection
	*builder.Base[T]
	// contains filtered or unexported fields
}

func NewProducerBuilder

func NewProducerBuilder[T any](topic string) (producer *ProducerBuilder[T])

func (*ProducerBuilder[T]) Build

func (p *ProducerBuilder[T]) Build() *Producer[T]