bufclient

type AppendChan = chan *v1.AppendRequest

type AppendStream struct {
	Stream v1.BufferService_AppendClient
	ReqCh  AppendChan
}

type AppendStreamPool struct {
	Ctx         context.Context // Every stream will have the same context
	ResCh       chan *v1.AppendResponse
	Streams     map[domain.BufferAddress]AppendChan
	DialOptions []grpc.DialOption
	// contains filtered or unexported fields
}