endpoint

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

type Conn interface {
	Expired() bool
	Send(val string) error
}

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

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
	}
}

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

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

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

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

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

type Protocol string

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

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