tunnel

Sep 12, 2023

Changes in this version

+ type AggregatingQuerier struct

+ func NewAggregatingQuerier(log *zap.Logger, delegate Querier, api modshared.Api, ...) *AggregatingQuerier

+ func (q *AggregatingQuerier) CachedKasUrlsByAgentId(agentId int64) []string

+ func (q *AggregatingQuerier) PollKasUrlsByAgentId(ctx context.Context, agentId int64, cb PollKasUrlsByAgentIdCallback)

+ func (q *AggregatingQuerier) Run(ctx context.Context) error

+ type DataCallback interface

+ Error func(*statuspb.Status) error

+ Header func(map[string]*prototool.Values) error

+ Message func([]byte) error

+ Trailer func(map[string]*prototool.Values) error

+ type FindHandle interface

+ Done func(ctx context.Context)

+ Get func(ctx context.Context) (Tunnel, error)

+ type Finder interface

+ FindTunnel func(ctx context.Context, agentId int64, service, method string) (bool, FindHandle)

+ type Handler interface

+ HandleTunnel func(ageCtx context.Context, agentInfo *api.AgentInfo, ...) error

+ type PollKasUrlsByAgentIdCallback func(kasUrls []string)

+ type PollingQuerier interface

+ CachedKasUrlsByAgentId func(agentId int64) []string

+ PollKasUrlsByAgentId func(ctx context.Context, agentId int64, cb PollKasUrlsByAgentIdCallback)

+ type Querier interface

+ KasUrlsByAgentId func(ctx context.Context, agentId int64) ([]string, error)

+ type RedisTracker struct

+ func NewRedisTracker(client rueidis.Client, agentKeyPrefix string, ttl time.Duration, ...) *RedisTracker

+ func (t *RedisTracker) KasUrlsByAgentId(ctx context.Context, agentId int64) ([]string, error)

+ func (t *RedisTracker) Refresh(ctx context.Context, nextRefresh time.Time) error

+ func (t *RedisTracker) RegisterTunnel(ctx context.Context, agentId int64) error

+ func (t *RedisTracker) UnregisterTunnel(ctx context.Context, agentId int64) error

+ type Registerer interface

+ Refresh func(ctx context.Context, nextRefresh time.Time) error

+ RegisterTunnel func(ctx context.Context, agentId int64) error

+ UnregisterTunnel func(ctx context.Context, agentId int64) error

+ type Registry struct

+ func NewRegistry(log *zap.Logger, api modshared.Api, tracer trace.Tracer, ...) (*Registry, error)

+ func (r *Registry) FindTunnel(ctx context.Context, agentId int64, service, method string) (bool, FindHandle)

+ func (r *Registry) HandleTunnel(ageCtx context.Context, agentInfo *api.AgentInfo, ...) error

+ func (r *Registry) KasUrlsByAgentId(ctx context.Context, agentId int64) ([]string, error)

+ func (r *Registry) Run(ctx context.Context) error

+ type RpcApi interface

+ HandleIoError func(log *zap.Logger, msg string, err error) error

+ type Tracker interface

+ type Tunnel interface

+ Done func(ctx context.Context)

+ ForwardStream func(log *zap.Logger, rpcApi RpcApi, incomingStream grpc.ServerStream, ...) error