kas

Documentation

Index

• type GitalyPool
• type Server
  • func (s *Server) GetConfiguration(req *agentrpc.ConfigurationRequest, stream agentrpc.Kas_GetConfigurationServer) error
  • func (s *Server) GetObjectsToSynchronize(req *agentrpc.ObjectsToSynchronizeRequest, ...) error

Types

type GitalyPool

type GitalyPool interface {
	CommitServiceClient(context.Context, *api.GitalyInfo) (gitalypb.CommitServiceClient, error)
}

type Server

type Server struct {
	Context                      context.Context
	GitalyPool                   GitalyPool
	GitLabClient                 gitlab.ClientInterface
	AgentConfigurationPollPeriod time.Duration
	GitopsPollPeriod             time.Duration
}

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