kas

Documentation

Index

• type Config
• type Server
  • func NewServer(config Config) (*Server, func(), error)
  • func (s *Server) GetConfiguration(req *agentrpc.ConfigurationRequest, stream agentrpc.Kas_GetConfigurationServer) error
  • func (s *Server) GetObjectsToSynchronize(req *agentrpc.ObjectsToSynchronizeRequest, ...) error
  • func (s *Server) Run(ctx context.Context)

Types

type Config

type Config struct {
	Log                          *zap.Logger
	GitalyPool                   gitaly.PoolInterface
	GitLabClient                 gitlab.ClientInterface
	AgentConfigurationPollPeriod time.Duration
	GitopsPollPeriod             time.Duration
	UsageReportingPeriod         time.Duration
	Registerer                   prometheus.Registerer
	Sentry                       sentryapi.Hub
}

type Server

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

func NewServer

func NewServer(config Config) (*Server, func(), error)

func (*Server) GetConfiguration

func (s *Server) GetConfiguration(req *agentrpc.ConfigurationRequest, stream agentrpc.Kas_GetConfigurationServer) error

func (*Server) GetObjectsToSynchronize

func (s *Server) GetObjectsToSynchronize(req *agentrpc.ObjectsToSynchronizeRequest, stream agentrpc.Kas_GetObjectsToSynchronizeServer) error

func (*Server) Run

func (s *Server) Run(ctx context.Context)