client

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

type ClientOptions struct {
	TargetServer    string
	ClusterUuid     string
	BearerToken     string
	LogLevel        string
	WorkersCount    int
	FixedFetchLimit int
	Version         string
	ConnOptions     ConnOptions
}

type ConnOptions struct {
	TLS                          *tls.Config
	MaxMsgSize                   int
	EnableKeepAlive              bool
	KeepAliveTime                time.Duration
	KeepAliveTimeout             time.Duration
	KeepAlivePermitWithoutStream bool
	UserDialOptions              []grpc.DialOption
}