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
		CACertFile string
		CertFile   string
		KeyFile    string
	}
	SQS struct {
		QueueID     string
		Region      string
		CredPath    string
		CredProfile string
		QueueName   string
	}
	NATS struct {
		Host  string
		Port  int
		User  string
		Pass  string
		Topic string
	}
	Local struct {
		Channel 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 LocalConn struct {
	// contains filtered or unexported fields
}

type LocalPublisher interface {
	Publish(channel string, message ...string) int
}

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

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

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