Documentation ¶
Index ¶
Constants ¶
View Source
const ( // 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") )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPConn ¶
type AMQPConn struct {
// contains filtered or unexported fields
}
AMQPConn is an endpoint connection
type DisqueConn ¶
type DisqueConn struct {
// contains filtered or unexported fields
}
DisqueConn is an endpoint connection
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 QueueName 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 } MQTT struct { Host string Port int QueueName string Qos byte Retained bool } SQS struct { QueueID string Region string CredPath string CredProfile string QueueName string } }
Endpoint represents an endpoint.
type GRPCConn ¶
type GRPCConn struct {
// contains filtered or unexported fields
}
GRPCConn is an endpoint connection
type HTTPConn ¶
type HTTPConn struct {
// contains filtered or unexported fields
}
HTTPConn is an endpoint connection
type KafkaConn ¶
type KafkaConn struct {
// contains filtered or unexported fields
}
KafkaConn is an endpoint connection
type MQTTConn ¶
type MQTTConn struct {
// contains filtered or unexported fields
}
MQTTConn is an endpoint connection
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager manages all endpoints
type RedisConn ¶
type RedisConn struct {
// contains filtered or unexported fields
}
RedisConn is an endpoint connection
Click to show internal directories.
Click to hide internal directories.