agent_tracker

package
v17.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 24, 2024 License: MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ModuleName = "agent_tracker"
)

Variables

View Source
var File_internal_module_agent_tracker_agent_tracker_proto protoreflect.FileDescriptor

Functions

func Expires added in v17.1.0

func Expires(t time.Time) zap.Field

Types

type AgentPodInfo

type AgentPodInfo struct {
	AgentId int64 `protobuf:"varint,1,opt,name=agent_id,proto3" json:"agent_id,omitempty"`
	PodId   int64 `protobuf:"varint,2,opt,name=pod_id,proto3" json:"pod_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentPodInfo) Descriptor deprecated

func (*AgentPodInfo) Descriptor() ([]byte, []int)

Deprecated: Use AgentPodInfo.ProtoReflect.Descriptor instead.

func (*AgentPodInfo) GetAgentId

func (x *AgentPodInfo) GetAgentId() int64

func (*AgentPodInfo) GetPodId

func (x *AgentPodInfo) GetPodId() int64

func (*AgentPodInfo) ProtoMessage

func (*AgentPodInfo) ProtoMessage()

func (*AgentPodInfo) ProtoReflect

func (x *AgentPodInfo) ProtoReflect() protoreflect.Message

func (*AgentPodInfo) Reset

func (x *AgentPodInfo) Reset()

func (*AgentPodInfo) String

func (x *AgentPodInfo) String() string

func (*AgentPodInfo) Validate added in v17.1.0

func (m *AgentPodInfo) Validate() error

Validate checks the field values on AgentPodInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AgentPodInfo) ValidateAll added in v17.1.0

func (m *AgentPodInfo) ValidateAll() error

ValidateAll checks the field values on AgentPodInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AgentPodInfoMultiError, or nil if none found.

type AgentPodInfoMultiError added in v17.1.0

type AgentPodInfoMultiError []error

AgentPodInfoMultiError is an error wrapping multiple validation errors returned by AgentPodInfo.ValidateAll() if the designated constraints aren't met.

func (AgentPodInfoMultiError) AllErrors added in v17.1.0

func (m AgentPodInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AgentPodInfoMultiError) Error added in v17.1.0

func (m AgentPodInfoMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AgentPodInfoValidationError added in v17.1.0

type AgentPodInfoValidationError struct {
	// contains filtered or unexported fields
}

AgentPodInfoValidationError is the validation error returned by AgentPodInfo.Validate if the designated constraints aren't met.

func (AgentPodInfoValidationError) Cause added in v17.1.0

Cause function returns cause value.

func (AgentPodInfoValidationError) Error added in v17.1.0

Error satisfies the builtin error interface

func (AgentPodInfoValidationError) ErrorName added in v17.1.0

func (e AgentPodInfoValidationError) ErrorName() string

ErrorName returns error name.

func (AgentPodInfoValidationError) Field added in v17.1.0

Field function returns field value.

func (AgentPodInfoValidationError) Key added in v17.1.0

Key function returns key value.

func (AgentPodInfoValidationError) Reason added in v17.1.0

Reason function returns reason value.

type ConnectedAgentInfo

type ConnectedAgentInfo struct {
	AgentMeta    *entity.AgentMeta      `protobuf:"bytes,1,opt,name=agent_meta,proto3" json:"agent_meta,omitempty"`
	ConnectedAt  *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=connected_at,proto3" json:"connected_at,omitempty"`
	ConnectionId int64                  `protobuf:"varint,3,opt,name=connection_id,proto3" json:"connection_id,omitempty"`
	AgentId      int64                  `protobuf:"varint,4,opt,name=agent_id,proto3" json:"agent_id,omitempty"`
	ProjectId    int64                  `protobuf:"varint,5,opt,name=project_id,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectedAgentInfo) Descriptor deprecated

func (*ConnectedAgentInfo) Descriptor() ([]byte, []int)

Deprecated: Use ConnectedAgentInfo.ProtoReflect.Descriptor instead.

func (*ConnectedAgentInfo) GetAgentId

func (x *ConnectedAgentInfo) GetAgentId() int64

func (*ConnectedAgentInfo) GetAgentMeta

func (x *ConnectedAgentInfo) GetAgentMeta() *entity.AgentMeta

func (*ConnectedAgentInfo) GetConnectedAt

func (x *ConnectedAgentInfo) GetConnectedAt() *timestamppb.Timestamp

func (*ConnectedAgentInfo) GetConnectionId

func (x *ConnectedAgentInfo) GetConnectionId() int64

func (*ConnectedAgentInfo) GetProjectId

func (x *ConnectedAgentInfo) GetProjectId() int64

func (*ConnectedAgentInfo) ProtoMessage

func (*ConnectedAgentInfo) ProtoMessage()

func (*ConnectedAgentInfo) ProtoReflect

func (x *ConnectedAgentInfo) ProtoReflect() protoreflect.Message

func (*ConnectedAgentInfo) Reset

func (x *ConnectedAgentInfo) Reset()

func (*ConnectedAgentInfo) String

func (x *ConnectedAgentInfo) String() string

func (*ConnectedAgentInfo) Validate added in v17.1.0

func (m *ConnectedAgentInfo) Validate() error

Validate checks the field values on ConnectedAgentInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ConnectedAgentInfo) ValidateAll added in v17.1.0

func (m *ConnectedAgentInfo) ValidateAll() error

ValidateAll checks the field values on ConnectedAgentInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ConnectedAgentInfoMultiError, or nil if none found.

type ConnectedAgentInfoCallback

type ConnectedAgentInfoCallback func(*ConnectedAgentInfo) (done bool, err error)

type ConnectedAgentInfoCollector

type ConnectedAgentInfoCollector []*ConnectedAgentInfo

func (*ConnectedAgentInfoCollector) Collect

type ConnectedAgentInfoMultiError added in v17.1.0

type ConnectedAgentInfoMultiError []error

ConnectedAgentInfoMultiError is an error wrapping multiple validation errors returned by ConnectedAgentInfo.ValidateAll() if the designated constraints aren't met.

func (ConnectedAgentInfoMultiError) AllErrors added in v17.1.0

func (m ConnectedAgentInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ConnectedAgentInfoMultiError) Error added in v17.1.0

Error returns a concatenation of all the error messages it wraps.

type ConnectedAgentInfoValidationError added in v17.1.0

type ConnectedAgentInfoValidationError struct {
	// contains filtered or unexported fields
}

ConnectedAgentInfoValidationError is the validation error returned by ConnectedAgentInfo.Validate if the designated constraints aren't met.

func (ConnectedAgentInfoValidationError) Cause added in v17.1.0

Cause function returns cause value.

func (ConnectedAgentInfoValidationError) Error added in v17.1.0

Error satisfies the builtin error interface

func (ConnectedAgentInfoValidationError) ErrorName added in v17.1.0

ErrorName returns error name.

func (ConnectedAgentInfoValidationError) Field added in v17.1.0

Field function returns field value.

func (ConnectedAgentInfoValidationError) Key added in v17.1.0

Key function returns key value.

func (ConnectedAgentInfoValidationError) Reason added in v17.1.0

Reason function returns reason value.

type DisconnectAgentInfo added in v17.1.0

type DisconnectAgentInfo struct {
	AgentMeta    *entity.AgentMeta `protobuf:"bytes,1,opt,name=agent_meta,proto3" json:"agent_meta,omitempty"`
	ConnectionId int64             `protobuf:"varint,2,opt,name=connection_id,proto3" json:"connection_id,omitempty"`
	AgentId      int64             `protobuf:"varint,3,opt,name=agent_id,proto3" json:"agent_id,omitempty"`
	ProjectId    int64             `protobuf:"varint,4,opt,name=project_id,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DisconnectAgentInfo) Descriptor deprecated added in v17.1.0

func (*DisconnectAgentInfo) Descriptor() ([]byte, []int)

Deprecated: Use DisconnectAgentInfo.ProtoReflect.Descriptor instead.

func (*DisconnectAgentInfo) GetAgentId added in v17.1.0

func (x *DisconnectAgentInfo) GetAgentId() int64

func (*DisconnectAgentInfo) GetAgentMeta added in v17.1.0

func (x *DisconnectAgentInfo) GetAgentMeta() *entity.AgentMeta

func (*DisconnectAgentInfo) GetConnectionId added in v17.1.0

func (x *DisconnectAgentInfo) GetConnectionId() int64

func (*DisconnectAgentInfo) GetProjectId added in v17.1.0

func (x *DisconnectAgentInfo) GetProjectId() int64

func (*DisconnectAgentInfo) ProtoMessage added in v17.1.0

func (*DisconnectAgentInfo) ProtoMessage()

func (*DisconnectAgentInfo) ProtoReflect added in v17.1.0

func (x *DisconnectAgentInfo) ProtoReflect() protoreflect.Message

func (*DisconnectAgentInfo) Reset added in v17.1.0

func (x *DisconnectAgentInfo) Reset()

func (*DisconnectAgentInfo) String added in v17.1.0

func (x *DisconnectAgentInfo) String() string

func (*DisconnectAgentInfo) Validate added in v17.1.0

func (m *DisconnectAgentInfo) Validate() error

Validate checks the field values on DisconnectAgentInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DisconnectAgentInfo) ValidateAll added in v17.1.0

func (m *DisconnectAgentInfo) ValidateAll() error

ValidateAll checks the field values on DisconnectAgentInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DisconnectAgentInfoMultiError, or nil if none found.

type DisconnectAgentInfoMultiError added in v17.1.0

type DisconnectAgentInfoMultiError []error

DisconnectAgentInfoMultiError is an error wrapping multiple validation errors returned by DisconnectAgentInfo.ValidateAll() if the designated constraints aren't met.

func (DisconnectAgentInfoMultiError) AllErrors added in v17.1.0

func (m DisconnectAgentInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DisconnectAgentInfoMultiError) Error added in v17.1.0

Error returns a concatenation of all the error messages it wraps.

type DisconnectAgentInfoValidationError added in v17.1.0

type DisconnectAgentInfoValidationError struct {
	// contains filtered or unexported fields
}

DisconnectAgentInfoValidationError is the validation error returned by DisconnectAgentInfo.Validate if the designated constraints aren't met.

func (DisconnectAgentInfoValidationError) Cause added in v17.1.0

Cause function returns cause value.

func (DisconnectAgentInfoValidationError) Error added in v17.1.0

Error satisfies the builtin error interface

func (DisconnectAgentInfoValidationError) ErrorName added in v17.1.0

ErrorName returns error name.

func (DisconnectAgentInfoValidationError) Field added in v17.1.0

Field function returns field value.

func (DisconnectAgentInfoValidationError) Key added in v17.1.0

Key function returns key value.

func (DisconnectAgentInfoValidationError) Reason added in v17.1.0

Reason function returns reason value.

type ExpiringRegisterer

type ExpiringRegisterer interface {
	// RegisterExpiring registers connection with the tracker.
	// Registration will expire if not refreshed using this method.
	RegisterExpiring(ctx context.Context, info *ConnectedAgentInfo) error
	// Unregister unregisters connection with the tracker.
	// This may be called to intentionally unregister the agent,
	// even though it may eventually expire.
	Unregister(ctx context.Context, info *DisconnectAgentInfo) error
}

type Querier

type Querier interface {
	GetConnectionsByAgentID(ctx context.Context, agentID int64, cb ConnectedAgentInfoCallback) error
	GetConnectionsByProjectID(ctx context.Context, projectID int64, cb ConnectedAgentInfoCallback) error
	GetConnectedAgentsCount(ctx context.Context) (int64, error)
	CountAgentsByAgentVersions(ctx context.Context) (map[string]int64, error)
}

type RedisTracker

type RedisTracker struct {
	// contains filtered or unexported fields
}

func NewRedisTracker

func NewRedisTracker(log *zap.Logger, errRep errz.ErrReporter, client rueidis.Client, agentKeyPrefix string,
	ttl, gcPeriod time.Duration, m otelmetric.Meter) (*RedisTracker, error)

func (*RedisTracker) CountAgentsByAgentVersions

func (t *RedisTracker) CountAgentsByAgentVersions(ctx context.Context) (map[string]int64, error)

func (*RedisTracker) GetConnectedAgentsCount

func (t *RedisTracker) GetConnectedAgentsCount(ctx context.Context) (int64, error)

func (*RedisTracker) GetConnectionsByAgentID

func (t *RedisTracker) GetConnectionsByAgentID(ctx context.Context, agentID int64, cb ConnectedAgentInfoCallback) error

func (*RedisTracker) GetConnectionsByProjectID

func (t *RedisTracker) GetConnectionsByProjectID(ctx context.Context, projectID int64, cb ConnectedAgentInfoCallback) error

func (*RedisTracker) RegisterExpiring

func (t *RedisTracker) RegisterExpiring(ctx context.Context, info *ConnectedAgentInfo) error

func (*RedisTracker) Run

func (t *RedisTracker) Run(ctx context.Context) error

func (*RedisTracker) Unregister added in v17.1.0

func (t *RedisTracker) Unregister(ctx context.Context, info *DisconnectAgentInfo) error

type Tracker

type Tracker interface {
	ExpiringRegisterer
	Querier
	Run(ctx context.Context) error
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL