loggregator

Documentation

Index

• type FakeLoggregatorIngressServer
  • func NewFakeLoggregatorIngressServer(serverCert, serverKey, caCert string) (*FakeLoggregatorIngressServer, error)
  • 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()

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()