Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EgressServerOption ¶
type EgressServerOption func(*TestEgressServer)
func WithAddr ¶
func WithAddr(addr string) EgressServerOption
func WithCN ¶
func WithCN(cn string) EgressServerOption
type TestEgressServer ¶
type TestEgressServer struct {
// contains filtered or unexported fields
}
func NewTestEgressServer ¶
func NewTestEgressServer(serverCert, serverKey, caCert string, opts ...EgressServerOption) (*TestEgressServer, error)
func (*TestEgressServer) Addr ¶
func (t *TestEgressServer) Addr() string
func (*TestEgressServer) Start ¶
func (t *TestEgressServer) Start(rxCallback func(*loggregator_v2.EgressRequest, loggregator_v2.Egress_ReceiverServer) error) error
func (*TestEgressServer) Stop ¶
func (t *TestEgressServer) Stop()
type TestIngressServer ¶
type TestIngressServer struct {
// contains filtered or unexported fields
}
func NewTestIngressServer ¶
func NewTestIngressServer(serverCert, serverKey, caCert string) (*TestIngressServer, error)
func (*TestIngressServer) Addr ¶
func (t *TestIngressServer) Addr() string
func (*TestIngressServer) Receivers ¶
func (t *TestIngressServer) Receivers() chan loggregator_v2.Ingress_BatchSenderServer
func (*TestIngressServer) Start ¶
func (t *TestIngressServer) Start() error
func (*TestIngressServer) Stop ¶
func (t *TestIngressServer) Stop()
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.