kas

Documentation

Index

• type Server
  • 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 Server

type Server struct {
	Context                      context.Context
	GitalyPool                   gitaly.PoolInterface
	GitLabClient                 gitlab.ClientInterface
	AgentConfigurationPollPeriod time.Duration
	GitopsPollPeriod             time.Duration
	UsageReportingPeriod         time.Duration
	// contains filtered or unexported fields
}

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)