mqclients

Documentation

Index

• Variables
• func GetEntry(m map[string]interface{}, key string) interface{}
• type JetStreamMQClient
  • func (jetstreamMQ *JetStreamMQClient) Channel() string
  • func (jetstreamMQ *JetStreamMQClient) Connect(ctx context.Context, clientName string, args map[string]interface{}) error
  • func (jetstreamMQ *JetStreamMQClient) Publish(ctx context.Context, channelName string, data []byte) error
  • func (jetstreamMQ *JetStreamMQClient) String() string
• type KafkaMQClient
  • func (kafkaMQ *KafkaMQClient) Channel() string
  • func (kafkaMQ *KafkaMQClient) Connect(ctx context.Context, clientName string, args map[string]interface{}) error
  • func (kafkaMQ *KafkaMQClient) Publish(ctx context.Context, channelName string, data []byte) error
  • func (kafkaMQ *KafkaMQClient) String() string
• type RedisMQClient
  • func (redisMQ *RedisMQClient) Channel() string
  • func (redisMQ *RedisMQClient) Connect(ctx context.Context, clientName string, args map[string]interface{}) error
  • func (redisMQ *RedisMQClient) Publish(ctx context.Context, channelName string, data []byte) error
  • func (redisMQ *RedisMQClient) String() string

Variables

var MQClients = []string{}

MQClients lists all current mqclients we have available.

Functions

func GetEntry

func GetEntry(m map[string]interface{}, key string) interface{}

Returns first match from a map and handles keys as non case sensitive.

Types

type JetStreamMQClient

type JetStreamMQClient struct {
	JetStreamClient jetstream.JetStream `json:"-"`
	JetStreamStream jetstream.Stream    `json:"-"`
	// contains filtered or unexported fields
}

func (*JetStreamMQClient) Channel

func (jetstreamMQ *JetStreamMQClient) Channel() string

func (*JetStreamMQClient) Connect

func (jetstreamMQ *JetStreamMQClient) Connect(ctx context.Context, clientName string, args map[string]interface{}) error

func (*JetStreamMQClient) Publish

func (jetstreamMQ *JetStreamMQClient) Publish(ctx context.Context, channelName string, data []byte) error

func (*JetStreamMQClient) String

func (jetstreamMQ *JetStreamMQClient) String() string

type KafkaMQClient

type KafkaMQClient struct {
	KafkaClient *kafka.Writer
	// contains filtered or unexported fields
}

func (*KafkaMQClient) Channel

func (kafkaMQ *KafkaMQClient) Channel() string

func (*KafkaMQClient) Connect

func (kafkaMQ *KafkaMQClient) Connect(ctx context.Context, clientName string, args map[string]interface{}) error

func (*KafkaMQClient) Publish

func (kafkaMQ *KafkaMQClient) Publish(ctx context.Context, channelName string, data []byte) error

func (*KafkaMQClient) String

func (kafkaMQ *KafkaMQClient) String() string

type RedisMQClient

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

func (*RedisMQClient) Channel

func (redisMQ *RedisMQClient) Channel() string

func (*RedisMQClient) Connect

func (redisMQ *RedisMQClient) Connect(ctx context.Context, clientName string, args map[string]interface{}) error

func (*RedisMQClient) Publish

func (redisMQ *RedisMQClient) Publish(ctx context.Context, channelName string, data []byte) error

func (*RedisMQClient) String

func (redisMQ *RedisMQClient) String() string