gitlab

Documentation

Index

• func IsForbidden(err error) bool
• type CacheOptions
• type CachingClient
  • func NewCachingClient(client ClientInterface, agentInfoCacheOptions CacheOptions, ...) *CachingClient
  • func (c *CachingClient) GetAgentInfo(ctx context.Context, agentMeta *api.AgentMeta) (*api.AgentInfo, error)
  • func (c *CachingClient) GetProjectInfo(ctx context.Context, agentMeta *api.AgentMeta, projectId string) (*api.ProjectInfo, error)
  • func (c *CachingClient) Run(ctx context.Context)
  • func (c *CachingClient) SendUsage(ctx context.Context, data *UsageData) error
• type Client
  • func NewClient(backend *url.URL, authSecret []byte, userAgent string) *Client
  • func (c *Client) GetAgentInfo(ctx context.Context, meta *api.AgentMeta) (*api.AgentInfo, error)
  • func (c *Client) GetProjectInfo(ctx context.Context, meta *api.AgentMeta, projectId string) (*api.ProjectInfo, error)
  • func (c *Client) SendUsage(ctx context.Context, data *UsageData) error
• type ClientError
  • func (c *ClientError) Error() string
• type ClientInterface
• type ErrorKind
• type HTTPClient
• type UsageData

Functions

func IsForbidden

func IsForbidden(err error) bool

Types

type CacheOptions

type CacheOptions struct {
	CacheTTL      time.Duration
	CacheErrorTTL time.Duration
}

CacheOptions holds cache behaviour configuration.

type CachingClient

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

CachingClient wraps ClientInterface to add caching.

func NewCachingClient

func NewCachingClient(client ClientInterface, agentInfoCacheOptions CacheOptions, projectInfoCacheOptions CacheOptions) *CachingClient

func (*CachingClient) GetAgentInfo

func (c *CachingClient) GetAgentInfo(ctx context.Context, agentMeta *api.AgentMeta) (*api.AgentInfo, error)

func (*CachingClient) GetProjectInfo

func (c *CachingClient) GetProjectInfo(ctx context.Context, agentMeta *api.AgentMeta, projectId string) (*api.ProjectInfo, error)

func (*CachingClient) Run

func (c *CachingClient) Run(ctx context.Context)

func (*CachingClient) SendUsage

func (c *CachingClient) SendUsage(ctx context.Context, data *UsageData) error

type Client

type Client struct {
	Backend    *url.URL
	HTTPClient HTTPClient
	AuthSecret []byte
	UserAgent  string
}

func NewClient

func NewClient(backend *url.URL, authSecret []byte, userAgent string) *Client

func (*Client) GetAgentInfo

func (c *Client) GetAgentInfo(ctx context.Context, meta *api.AgentMeta) (*api.AgentInfo, error)

func (*Client) GetProjectInfo

func (c *Client) GetProjectInfo(ctx context.Context, meta *api.AgentMeta, projectId string) (*api.ProjectInfo, error)

func (*Client) SendUsage

func (c *Client) SendUsage(ctx context.Context, data *UsageData) error

type ClientError

type ClientError struct {
	Kind       ErrorKind
	StatusCode int
}

func (*ClientError) Error

func (c *ClientError) Error() string

type ClientInterface

type ClientInterface interface {
	GetAgentInfo(ctx context.Context, agentMeta *api.AgentMeta) (*api.AgentInfo, error)
	GetProjectInfo(ctx context.Context, agentMeta *api.AgentMeta, projectId string) (*api.ProjectInfo, error)
	SendUsage(ctx context.Context, data *UsageData) error
}

type ErrorKind

type ErrorKind int

const (
	ErrorKindOther ErrorKind = iota
	ErrorKindForbidden
)

type HTTPClient

type HTTPClient interface {
	Do(*http.Request) (*http.Response, error)
}

type UsageData

type UsageData struct {
	GitopsSyncCount int64 `json:"gitops_sync_count"`
}