channel

Documentation

Overview

nolint because this is temporally here and will be moved under meshkit

Index

• Variables
• type ChannelBrokerHandler
  • func NewChannelBrokerHandler(optsSetters ...OptionsSetter) *ChannelBrokerHandler
  • func (h *ChannelBrokerHandler) CloseConnection()
  • func (h *ChannelBrokerHandler) ConnectedEndpoints() (endpoints []string)
  • func (h *ChannelBrokerHandler) DeepCopy() realBroker.Handler
  • func (h *ChannelBrokerHandler) DeepCopyInto(out realBroker.Handler)
  • func (h *ChannelBrokerHandler) DeepCopyObject() realBroker.Handler
  • func (h *ChannelBrokerHandler) Info() string
  • func (h *ChannelBrokerHandler) IsEmpty() bool
  • func (h *ChannelBrokerHandler) Publish(subject string, message *realBroker.Message) error
  • func (h *ChannelBrokerHandler) PublishWithChannel(subject string, msgch chan *realBroker.Message) error
  • func (h *ChannelBrokerHandler) Subscribe(subject, queue string, message []byte) error
  • func (h *ChannelBrokerHandler) SubscribeWithChannel(subject, queue string, msgch chan *realBroker.Message) error
• type ErrChannelBrokerPublishType
  • func NewErrChannelBrokerPublish(err error, successQueueList []string, failedQueueList []string) *ErrChannelBrokerPublishType
  • func (e *ErrChannelBrokerPublishType) Error() string
• type Options
• type OptionsSetter
  • func WithPublishToChannelDelay(value time.Duration) OptionsSetter
  • func WithSingleChannelBufferSize(value uint) OptionsSetter

Variables

var DefaultOptions = Options{
	SingleChannelBufferSize: 1024,
	PublishToChannelDelay:   1 * time.Second,
}

Types

type ChannelBrokerHandler

type ChannelBrokerHandler struct {
	Options
	// contains filtered or unexported fields
}

func NewChannelBrokerHandler

func NewChannelBrokerHandler(optsSetters ...OptionsSetter) *ChannelBrokerHandler

func (*ChannelBrokerHandler) CloseConnection

func (h *ChannelBrokerHandler) CloseConnection()

func (*ChannelBrokerHandler) ConnectedEndpoints

func (h *ChannelBrokerHandler) ConnectedEndpoints() (endpoints []string)

func (*ChannelBrokerHandler) DeepCopy

func (h *ChannelBrokerHandler) DeepCopy() realBroker.Handler

DeepCopy is a deepcopy function, copying the receiver, creating a new Nats.

func (*ChannelBrokerHandler) DeepCopyInto

func (h *ChannelBrokerHandler) DeepCopyInto(out realBroker.Handler)

DeepCopyInto is a deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ChannelBrokerHandler) DeepCopyObject

func (h *ChannelBrokerHandler) DeepCopyObject() realBroker.Handler

DeepCopyObject is a deepcopy function, copying the receiver, creating a new realBroker.Handler.

func (*ChannelBrokerHandler) Info

func (h *ChannelBrokerHandler) Info() string

func (*ChannelBrokerHandler) IsEmpty

func (h *ChannelBrokerHandler) IsEmpty() bool

Check if the connection object is empty

func (*ChannelBrokerHandler) Publish

func (h *ChannelBrokerHandler) Publish(subject string, message *realBroker.Message) error

Publish - to publish messages

func (*ChannelBrokerHandler) PublishWithChannel

func (h *ChannelBrokerHandler) PublishWithChannel(subject string, msgch chan *realBroker.Message) error

PublishWithChannel - to publish messages with channel

func (*ChannelBrokerHandler) Subscribe

func (h *ChannelBrokerHandler) Subscribe(subject, queue string, message []byte) error

Subscribe - for subscribing messages

func (*ChannelBrokerHandler) SubscribeWithChannel

func (h *ChannelBrokerHandler) SubscribeWithChannel(subject, queue string, msgch chan *realBroker.Message) error

SubscribeWithChannel will publish all the messages received to the given channel

type ErrChannelBrokerPublishType

type ErrChannelBrokerPublishType struct {
	Err              error
	SuccessQueueList []string
	FailedQueueList  []string
}

func NewErrChannelBrokerPublish

func NewErrChannelBrokerPublish(
	err error,
	successQueueList []string,
	failedQueueList []string,
) *ErrChannelBrokerPublishType

func (*ErrChannelBrokerPublishType) Error

func (e *ErrChannelBrokerPublishType) Error() string

type Options

type Options struct {
	SingleChannelBufferSize uint
	PublishToChannelDelay   time.Duration
}

type OptionsSetter

type OptionsSetter func(*Options)

func WithPublishToChannelDelay

func WithPublishToChannelDelay(value time.Duration) OptionsSetter

func WithSingleChannelBufferSize

func WithSingleChannelBufferSize(value uint) OptionsSetter