modserver

Jul 16, 2025

Changes in this version

type AgentRPCAPI

+ AgentTokenWithType func() api.AgentTokenWithType

May 14, 2025

Changes in this version

+ const GRPCMethodSentryField

+ const GRPCServiceSentryField

+ const SentryFieldTraceID

+ const SentryFieldTraceSampled

+ func InjectAgentRPCAPI(ctx context.Context, rpcAPI AgentRPCAPI) context.Context

+ func StreamAgentRPCAPIInterceptor(factory AgentRPCAPIFactory) grpc.StreamServerInterceptor

+ func UnaryAgentRPCAPIInterceptor(factory AgentRPCAPIFactory) grpc.UnaryServerInterceptor

+ type API interface

+ OnGitPushEvent func(ctx context.Context, cb syncz.EventCallback[*event.GitPushEvent])

+ type AgentInfoResolver interface

+ Get func(ctx context.Context, agentID int64) (map[string]any, error)

+ type AgentRPCAPI interface

+ AgentInfo func(ctx context.Context, log *slog.Logger) (*api.AgentInfo, error)

+ AgentToken func() api.AgentToken

+ func AgentRPCAPIFromContext(ctx context.Context) AgentRPCAPI

+ type AgentRPCAPIFactory func(ctx context.Context, fullMethodName string) (AgentRPCAPI, error)

+ type ApplyDefaults func(*kascfg.ConfigurationFile)

+ type Config struct

+ API API

+ APIServer grpctool.GRPCServer

+ AgentConnPool func(agentID int64) grpc.ClientConnInterface

+ AgentServer grpctool.GRPCServer

+ Config *kascfg.ConfigurationFile

+ EventTracker event_tracker.EventTrackerRegisterer

+ GRPCClientTracing bool

+ GRPCServerTracing bool

+ GitLabClient gitlab.ClientInterface

+ GitLabReleasesList []string

+ GitRef string

+ Gitaly gitaly.PoolInterface

+ HTTPClientTracing bool

+ HTTPServerTracing bool

+ InstanceID int64

+ KASName string

+ KASNameVersion string

+ ListenerMetrics func(l net.Listener, name string, ttl time.Duration) (net.Listener, error)

+ Log *slog.Logger

+ Meter otelmetric.Meter

+ MeterProvider otelmetric.MeterProvider

+ ProbeRegistry *observability.ProbeRegistry

+ RedisClient rueidis.Client

+ RegisterAgentAPI func(*grpc.ServiceDesc)

+ StreamClientProm grpc.StreamClientInterceptor

+ TracePropagator propagation.TextMapPropagator

+ TraceProvider trace.TracerProvider

+ UnaryClientProm grpc.UnaryClientInterceptor

+ UsageTracker usage_metrics.UsageTrackerRegisterer

+ Validator protovalidate.Validator

+ Version version.Version

+ func (c *Config) MaybeTraceProvider(flag bool) trace.TracerProvider

+ type Factory interface

+ New func(*Config) (Module, error)

+ type Module interface

+ Name func() string

+ Run func(context.Context) error