mqclients

package

v0.0.0-...-43d1068 Latest Latest Go to latest Published: Feb 16, 2024 License: MIT Imports: 12 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/WelcomerTeam/Sandwich

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func GetEntry(m map[string]interface{}, key string) interface{}
type KafkaMQClient
- func NewKafkaMQClient() (mqC *KafkaMQClient)
type RedisMQClient
- func NewRedisMQClient() (mqC *RedisMQClient)
type StanMQClient
- func NewStanMQClient() (mqC *StanMQClient)

Constants ¶

View Source

const MsgChannelBuffer = 32

Variables ¶

View Source

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 KafkaMQClient ¶

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

func NewKafkaMQClient ¶

func NewKafkaMQClient() (mqC *KafkaMQClient)

func (*KafkaMQClient) Chan ¶

func (kafkaMQ *KafkaMQClient) Chan() (ch chan []byte)

func (*KafkaMQClient) Channel ¶

func (kafkaMQ *KafkaMQClient) Channel() string

func (*KafkaMQClient) Cluster ¶

func (kafkaMQ *KafkaMQClient) Cluster() string

func (*KafkaMQClient) Connect ¶

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

func (*KafkaMQClient) String ¶

func (kafkaMQ *KafkaMQClient) String() string

func (kafkaMQ *KafkaMQClient) Subscribe(ctx context.Context, channelName string) error

func (*KafkaMQClient) Unsubscribe ¶

func (kafkaMQ *KafkaMQClient) Unsubscribe()

type RedisMQClient ¶

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

func NewRedisMQClient ¶

func NewRedisMQClient() (mqC *RedisMQClient)

func (*RedisMQClient) Chan ¶

func (redisMQ *RedisMQClient) Chan() (ch chan []byte)

func (*RedisMQClient) Channel ¶

func (redisMQ *RedisMQClient) Channel() string

func (*RedisMQClient) Cluster ¶

func (redisMQ *RedisMQClient) Cluster() string

func (*RedisMQClient) Connect ¶

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

func (*RedisMQClient) String ¶

func (redisMQ *RedisMQClient) String() string

func (redisMQ *RedisMQClient) Subscribe(ctx context.Context, channel string) error

func (*RedisMQClient) Unsubscribe ¶

func (redisMQ *RedisMQClient) Unsubscribe()

type StanMQClient ¶

type StanMQClient struct {
	NatsClient *nats.Conn `json:"-"`
	StanClient stan.Conn  `json:"-"`
	// contains filtered or unexported fields
}

func NewStanMQClient ¶

func NewStanMQClient() (mqC *StanMQClient)

func (*StanMQClient) Chan ¶

func (stanMQ *StanMQClient) Chan() (ch chan []byte)

func (*StanMQClient) Channel ¶

func (stanMQ *StanMQClient) Channel() string

func (*StanMQClient) Cluster ¶

func (stanMQ *StanMQClient) Cluster() string

func (*StanMQClient) Connect ¶

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

func (*StanMQClient) String ¶

func (stanMQ *StanMQClient) String() string

func (stanMQ *StanMQClient) Subscribe(ctx context.Context, channelName string) error

func (*StanMQClient) Unsubscribe ¶

func (stanMQ *StanMQClient) Unsubscribe()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL