natsrpc

type Conn struct {
	sync.Mutex

	AsyncMaxPending int
	// contains filtered or unexported fields
}

type INatsStream interface {
	Send(*ss.Message) error
	Recv() (*ss.Message, error)
	// Context returns the context for this stream.
	Context() nats.JetStreamContext
	Close()
}

type NatsConfig struct {
	ServiceType         int            `mapstructure:"service_type"`
	ServiceID           int            `mapstructure:"service_id"`
	Nats                []string       `mapstructure:"nats"`
	Services            []ServiceGroup `mapstructure:"services"`
	PingInterval        time.Duration  `mapstructure:"ping_interval"`
	MaxPingsOutstanding int            `mapstructure:"max_ping_outstanding"`
	QueueSize           int            `mapstructure:"queue_size"`
	SocketQueueSize     int            `mapstructure:"socket_queue_size"`
	AsyncMaxPending     uint32         `mapstructure:"async_max_pending"`
	WorkerPoolCapacity  int            `mapstructure:"worker_pool_capacity"`
	WorkerPoolQueueSize int            `mapstructure:"worker_pool_queue_size"`
}

type NatsRPC struct {
	sync.Mutex
	Conf       *NatsConfig
	NewAgent   network.AgentCreateFunc
	CloseAgent network.AgentCloseFunc
	// contains filtered or unexported fields
}

type ServiceGroup struct {
	Key     string `mapstructure:"key" json:"key"`
	Type    int    `mapstructure:"type" json:"type"`
	Version int    `mapstructure:"version" json:"version"`
	Mode    int    `mapstructure:"mode" json:"mode"`
	Hash    []int  `mapstructure:"hash"  json:"hash"`
}