broker

type BConfig struct {
	Reset int
}

type Bridge struct {
	Name  string
	Kafka Kafka
}

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

type Client struct {
	Retry       int
	Reset       int
	WaitConnect int
	Connection  Connection
}

type Cluster struct {
	Enable              bool
	External            string
	Host                string
	TcpPort             int
	LeaseKeyPrefix      string
	Lease               int64
	RenewLeaseInterval  int64
	SyncBrokersInterval int64
	PeerConnMaxInterval int
	Etcd                Etcd
	Proxy               Proxy
}

type Config struct {
	Title    string
	Owner    Owner
	Mode     Mode
	Broker   BConfig
	Serve    Serve
	Client   Client
	Peer     Peer
	Cluster  Cluster
	Session  Session
	Receiver Receiver
	Sender   Sender
	Bridge   Bridge
}

type ConnStatus int32

type ConnType int32

type Connection struct {
	Max uint64
}

type DeliverMap struct {
	Key   string
	Value string
}

type Etcd struct {
	Endpoints []string
	Timeout   int64
}

type GRPC struct {
	Host string
	Port int
}

type HTTP struct {
	Host string
	Port int
}

type InflightPacket struct {
	Packet packets.ControlPacket
	Time   time.Time
}

type Kafka struct {
	Endpoints     []string
	OnConnect     string
	OnPublish     string
	OnSubscribe   string
	OnDisconnect  string
	OnUnsubscribe string
	DeliverMap    []DeliverMap
}

type Mode struct {
	Debug bool
}

type Owner struct {
	Name    string
	Created time.Time
	Updated time.Time
}

type Peer struct {
	Reset int
}

type Proxy struct {
	PoolSize         int
	Retry            int
	SendTimeout      int
	AckChan          int
	SendSubUnsubChan int
	Inflight         int
	SubUnsubQueue    int
}

type Receiver struct {
	Client ReceiverConfig
	Peer   ReceiverConfig
}

type ReceiverConfig struct {
	RecvChan int
}

type Sender struct {
	Retry   int
	Timeout int
	Client  SenderConfig
	Peer    SenderConfig
}

type SenderConfig struct {
	AckChan int
	PubChan int
}

type Serve struct {
	GRPC GRPC
	HTTP HTTP
	TCP  TCP
	TLS  TLS
	WS   WS
	WSS  WSS
}

type Session struct {
	Client SessionConfig
	Peer   SessionConfig
}

type SessionConfig struct {
	ZQueue   int
	OTQueue  int
	Inflight int
}

type TCP struct {
	Enable bool
	Host   string
	Port   int
}

type TLS struct {
	Enable  bool
	Host    string
	Port    int
	Verify  bool
	CaPem   string
	CertPem string
	KeyPem  string
}

type TopicType int32

type WS struct {
	Enable bool
	Host   string
	Port   int
	Path   string
}

type WSS struct {
	Enable  bool
	Host    string
	Port    int
	Path    string
	CaPem   string
	CertPem string
	KeyPem  string
}