Documentation
¶
Index ¶
Constants ¶
const ( // Local protocol Local = Protocol("local") // HTTP protocol HTTP = Protocol("http") // Disque protocol Disque = Protocol("disque") // GRPC protocol GRPC = Protocol("grpc") // Redis protocol Redis = Protocol("redis") // Kafka protocol Kafka = Protocol("kafka") // MQTT protocol MQTT = Protocol("mqtt") // AMQP protocol AMQP = Protocol("amqp") // SQS protocol SQS = Protocol("sqs") // Google Cloud Pubsub protocol PubSub = Protocol("pubsub") // NATS protocol NATS = Protocol("nats") // EventHub protocol EventHub = Protocol("sb") )
Variables ¶
var ( SHA256 scram.HashGeneratorFcn = sha256.New SHA512 scram.HashGeneratorFcn = sha512.New )
Functions ¶
This section is empty.
Types ¶
type AMQPConn ¶
type AMQPConn struct {
// contains filtered or unexported fields
}
AMQPConn is an endpoint connection
func (*AMQPConn) ExpireNow ¶
func (conn *AMQPConn) ExpireNow()
ExpireNow forces the connection to expire
type DisqueConn ¶
type DisqueConn struct {
// contains filtered or unexported fields
}
DisqueConn is an endpoint connection
func (*DisqueConn) ExpireNow ¶
func (conn *DisqueConn) ExpireNow()
ExpireNow forces the connection to expire
func (*DisqueConn) Expired ¶
func (conn *DisqueConn) Expired() bool
Expired returns true if the connection has expired
type Endpoint ¶
type Endpoint struct {
Protocol Protocol
Original string
GRPC struct {
Host string
Port int
}
Disque struct {
Host string
Port int
QueueName string
Options struct {
Replicate int
}
}
Redis struct {
Host string
Port int
Channel string
}
Kafka struct {
Host string
Port int
TopicName string
Auth string
SSL bool
SASLSHA256 bool
SASLSHA512 bool
CACertFile string
CertFile string
KeyFile string
}
AMQP struct {
URI string
SSL bool
QueueName string
RouteKey string
Type string
Durable bool
AutoDelete bool
Internal bool
NoWait bool
Mandatory bool
Immediate bool
DeliveryMode uint8
Priority uint8
}
MQTT struct {
Host string
Port int
QueueName string
Qos byte
Retained bool
CACertFile string
CertFile string
KeyFile string
}
PubSub struct {
Project string
Topic string
CredPath string
}
SQS struct {
PlainURL string
QueueID string
Region string
CredPath string
CredProfile string
QueueName string
CreateQueue bool
}
NATS struct {
Host string
Port int
User string
Pass string
Topic string
Token string
TLS bool
TLSCert string
TLSKey string
}
EventHub struct {
ConnectionString string
}
Local struct {
Channel string
}
}
Endpoint represents an endpoint.
type EvenHubConn ¶
type EvenHubConn struct {
// contains filtered or unexported fields
}
HTTPConn is an endpoint connection
func (*EvenHubConn) ExpireNow ¶
func (conn *EvenHubConn) ExpireNow()
ExpireNow forces the connection to expire
func (*EvenHubConn) Expired ¶
func (conn *EvenHubConn) Expired() bool
Expired returns true if the connection has expired
type GRPCConn ¶
type GRPCConn struct {
// contains filtered or unexported fields
}
GRPCConn is an endpoint connection
func (*GRPCConn) ExpireNow ¶
func (conn *GRPCConn) ExpireNow()
ExpireNow forces the connection to expire
type HTTPConn ¶
type HTTPConn struct {
// contains filtered or unexported fields
}
HTTPConn is an endpoint connection
func (*HTTPConn) ExpireNow ¶
func (conn *HTTPConn) ExpireNow()
ExpireNow forces the connection to expire
type KafkaConn ¶
type KafkaConn struct {
// contains filtered or unexported fields
}
KafkaConn is an endpoint connection
func (*KafkaConn) ExpireNow ¶
func (conn *KafkaConn) ExpireNow()
ExpireNow forces the connection to expire
type LocalConn ¶
type LocalConn struct {
// contains filtered or unexported fields
}
LocalConn is an endpoint connection
func (*LocalConn) ExpireNow ¶
func (conn *LocalConn) ExpireNow()
ExpireNow forces the connection to expire
type LocalPublisher ¶
LocalPublisher is used to publish local notifications
type MQTTConn ¶
type MQTTConn struct {
// contains filtered or unexported fields
}
MQTTConn is an endpoint connection
func (*MQTTConn) ExpireNow ¶
func (conn *MQTTConn) ExpireNow()
ExpireNow forces the connection to expire
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager manages all endpoints
func NewManager ¶
func NewManager(publisher LocalPublisher) *Manager
NewManager returns a new manager
type NATSConn ¶
type NATSConn struct {
// contains filtered or unexported fields
}
NATSConn is an endpoint connection
func (*NATSConn) ExpireNow ¶
func (conn *NATSConn) ExpireNow()
ExpireNow forces the connection to expire
type PubSubConn ¶
type PubSubConn struct {
// contains filtered or unexported fields
}
SQSConn is an endpoint connection
func (*PubSubConn) ExpireNow ¶
func (conn *PubSubConn) ExpireNow()
ExpireNow forces the connection to expire
func (*PubSubConn) Expired ¶
func (conn *PubSubConn) Expired() bool
type RedisConn ¶
type RedisConn struct {
// contains filtered or unexported fields
}
RedisConn is an endpoint connection
func (*RedisConn) ExpireNow ¶
func (conn *RedisConn) ExpireNow()
ExpireNow forces the connection to expire
type SQSConn ¶
type SQSConn struct {
// contains filtered or unexported fields
}
SQSConn is an endpoint connection
func (*SQSConn) ExpireNow ¶
func (conn *SQSConn) ExpireNow()
ExpireNow forces the connection to expire
type XDGSCRAMClient ¶
type XDGSCRAMClient struct {
*scram.Client
*scram.ClientConversation
scram.HashGeneratorFcn
}
func (*XDGSCRAMClient) Begin ¶
func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)
func (*XDGSCRAMClient) Done ¶
func (x *XDGSCRAMClient) Done() bool
Source Files