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