Documentation ¶
Index ¶
- func NewClientMutualTLSConfig(certFile string, keyFile string, caCertFile string, serverName string) (*tls.Config, error)
- func NewServerMutualTLSConfig(certFile, keyFile, caCertFile string) (*tls.Config, error)
- type FakeEventProducer
- func (f *FakeEventProducer) BatchedReceiver(req *loggregator_v2.EgressBatchRequest, ...) error
- func (f *FakeEventProducer) GetActualReq() *loggregator_v2.EgressBatchRequest
- func (f *FakeEventProducer) GetAddr() string
- func (f *FakeEventProducer) GetConnectionAttempts() int
- func (f *FakeEventProducer) Receiver(*loggregator_v2.EgressRequest, loggregator_v2.Egress_ReceiverServer) error
- func (f *FakeEventProducer) SetEnvelops(envelops []*loggregator_v2.Envelope)
- func (f *FakeEventProducer) Start()
- func (f *FakeEventProducer) Stop() bool
- type KeepAlive
- type WebsocketHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type FakeEventProducer ¶
type FakeEventProducer struct {
// contains filtered or unexported fields
}
func NewFakeEventProducer ¶
func (*FakeEventProducer) BatchedReceiver ¶
func (f *FakeEventProducer) BatchedReceiver( req *loggregator_v2.EgressBatchRequest, srv loggregator_v2.Egress_BatchedReceiverServer, ) error
func (*FakeEventProducer) GetActualReq ¶
func (f *FakeEventProducer) GetActualReq() *loggregator_v2.EgressBatchRequest
func (*FakeEventProducer) GetAddr ¶
func (f *FakeEventProducer) GetAddr() string
func (*FakeEventProducer) GetConnectionAttempts ¶
func (f *FakeEventProducer) GetConnectionAttempts() int
func (*FakeEventProducer) Receiver ¶
func (f *FakeEventProducer) Receiver( *loggregator_v2.EgressRequest, loggregator_v2.Egress_ReceiverServer, ) error
func (*FakeEventProducer) SetEnvelops ¶
func (f *FakeEventProducer) SetEnvelops(envelops []*loggregator_v2.Envelope)
func (*FakeEventProducer) Start ¶
func (f *FakeEventProducer) Start()
func (*FakeEventProducer) Stop ¶
func (f *FakeEventProducer) Stop() bool
type KeepAlive ¶
type KeepAlive struct {
// contains filtered or unexported fields
}
func NewKeepAlive ¶
type WebsocketHandler ¶
type WebsocketHandler struct {
// contains filtered or unexported fields
}
func NewWebsocketHandler ¶
func NewWebsocketHandler(m chan []byte, pingPongChan chan int, keepAlive time.Duration) *WebsocketHandler
func (*WebsocketHandler) CloseWSConnection ¶
func (h *WebsocketHandler) CloseWSConnection()
func (*WebsocketHandler) ServeWebsocket ¶
func (h *WebsocketHandler) ServeWebsocket(rw http.ResponseWriter, r *http.Request)
Click to show internal directories.
Click to hide internal directories.