Documentation
¶
Overview ¶
This package provides a multiplexer for combine one or more gRPC event streams into a single stream. Useful for running the eventchecker across multiple gRPC connections simultaneously, for example in a multi-node cluster.
Index ¶
- func ConnectAttempt(ctx context.Context, addr string) (*grpc.ClientConn, error)
- type ClientMultiplexer
- func (cm *ClientMultiplexer) GetEvents(ctx context.Context, allowList, denyList []*tetragon.Filter) (chan GetEventsResult, error)
- func (cm *ClientMultiplexer) SetConns(conns []*grpc.ClientConn)
- func (cm *ClientMultiplexer) WithConnectBackoff(backoff time.Duration) *ClientMultiplexer
- func (cm *ClientMultiplexer) WithConnectRetries(retries uint) *ClientMultiplexer
- type GetEventsResult
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConnectAttempt ¶ added in v1.4.1
Types ¶
type ClientMultiplexer ¶
type ClientMultiplexer struct {
// contains filtered or unexported fields
}
ClientMultiplexer multiplexes one or more GetEvents clients into a single stream
func NewClientMultiplexer ¶
func NewClientMultiplexer() *ClientMultiplexer
NewClientMultiplexer constructs a new ClientMultiplexer.
func (*ClientMultiplexer) GetEvents ¶
func (cm *ClientMultiplexer) GetEvents(ctx context.Context, allowList, denyList []*tetragon.Filter) (chan GetEventsResult, error)
GetEventsWithFilters calls GetEvents for each client in the multiplexer and returns a channel that multiplexes the GetEventsResponses. allowList and denyList can be used to filter what events we care about.
func (*ClientMultiplexer) SetConns ¶ added in v1.4.1
func (cm *ClientMultiplexer) SetConns(conns []*grpc.ClientConn)
func (*ClientMultiplexer) WithConnectBackoff ¶
func (cm *ClientMultiplexer) WithConnectBackoff(backoff time.Duration) *ClientMultiplexer
WithConnectBackoff updates the backoff time between connection attempts to each gRPC server. The default is 1 second.
func (*ClientMultiplexer) WithConnectRetries ¶
func (cm *ClientMultiplexer) WithConnectRetries(retries uint) *ClientMultiplexer
WithConnectRetries updates the number of attempts this multiplexer will make to connect to each gRPC server. The default is 10.
type GetEventsResult ¶
type GetEventsResult struct {
*tetragon.GetEventsResponse
Error error
}
GetEventsResult encapsulates a GetEventsResponse and an error
Source Files