stream

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

type ClientRecvFromServerReqFunc func(*protos.ClientToServer) (bool, *protos.ServerToClient, error)

type ClientStatusChangeFunc func(defs.Status, control.ClientUID) error

type FromS interface {
	*protos.ServerToClient | *protos.ServerToSampler
}

type Handler[T ToS, F FromS] interface {
	// contains filtered or unexported methods
}

type Options struct {
	// RegistrationReqTimeout is a duration for the maximum amount of time to wait
	// for a registration request after a new client/sampler connection.
	RegistrationReqTimeout time.Duration
	// ResponseTimeout is a duration for the maximum amount of time to wait
	// for a response to a request send to the client/sampler.
	ResponseTimeout time.Duration
	// ServerReqsQueueLen defines how many client/sampler requests are allowed to be queued.
	ReqsQueueLen int
}

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

type SamplerRecvFromServerReqFunc func(*protos.SamplerToServer) (bool, *protos.ServerToSampler, error)

type SamplerStatusChangeFunc func(defs.Status, control.SamplerUID, *protos.SamplerToServer) error

type Stream[T ToS, F FromS] struct {
	UID       string
	ServerUID string
	// contains filtered or unexported fields
}

type ToS interface {
	*protos.ClientToServer | *protos.SamplerToServer
}