Documentation ¶
Index ¶
- type FakeLoggregatorIngressServer
- func (t *FakeLoggregatorIngressServer) BatchSender(srv loggregator_v2.Ingress_BatchSenderServer) error
- func (t *FakeLoggregatorIngressServer) Send(_ context.Context, b *loggregator_v2.EnvelopeBatch) (*loggregator_v2.SendResponse, error)
- func (t *FakeLoggregatorIngressServer) Sender(srv loggregator_v2.Ingress_SenderServer) error
- func (t *FakeLoggregatorIngressServer) Start() error
- func (t *FakeLoggregatorIngressServer) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeLoggregatorIngressServer ¶
type FakeLoggregatorIngressServer struct { ReceivedEnvelopes chan *loggregator_v2.Envelope Addr string grpc.Stream // contains filtered or unexported fields }
func NewFakeLoggregatorIngressServer ¶
func NewFakeLoggregatorIngressServer(serverCert, serverKey, caCert string) (*FakeLoggregatorIngressServer, error)
func (*FakeLoggregatorIngressServer) BatchSender ¶
func (t *FakeLoggregatorIngressServer) BatchSender(srv loggregator_v2.Ingress_BatchSenderServer) error
func (*FakeLoggregatorIngressServer) Send ¶
func (t *FakeLoggregatorIngressServer) Send(_ context.Context, b *loggregator_v2.EnvelopeBatch) (*loggregator_v2.SendResponse, error)
func (*FakeLoggregatorIngressServer) Sender ¶
func (t *FakeLoggregatorIngressServer) Sender(srv loggregator_v2.Ingress_SenderServer) error
func (*FakeLoggregatorIngressServer) Start ¶
func (t *FakeLoggregatorIngressServer) Start() error
func (*FakeLoggregatorIngressServer) Stop ¶
func (t *FakeLoggregatorIngressServer) Stop()
Click to show internal directories.
Click to hide internal directories.