gitclient

Documentation

Index

• type Client
  • func NewClient(innerClient IStatelessClient, name string, gitOwnerRepo string, ...) Client
  • func (c *Client) GetQueuedJobs(ctx context.Context) ([]*github.WorkflowRun, *time.Time, error)
  • func (c *Client) GetState() (*state.ClientState, error)
  • func (c *Client) GetWorkflowInfo(ctx context.Context) (map[int64]utils.WorkflowInfo, error)
  • func (c *Client) SaveState(state *state.ClientState) error
• type GithubClient
  • func NewGitHubClient(token string, owner string, repository string) GithubClient
  • func (c *GithubClient) GetQueuedJobs(ctx context.Context) ([]*github.WorkflowRun, error)
  • func (c *GithubClient) GetRemainingCreditsForToken(ctx context.Context) (string, string, int, error)
  • func (c *GithubClient) GetWorkflowData(ctx context.Context) (*map[int64]utils.WorkflowInfo, error)
• type IClient
• type IStatelessClient
• type Status

Types

type Client

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

func NewClient

func NewClient(innerClient IStatelessClient, name string, gitOwnerRepo string, cacheWindow time.Duration, cacheWindowWhenEmpty time.Duration, stateProvider state.IStateProvider) Client

func (*Client) GetQueuedJobs

func (c *Client) GetQueuedJobs(ctx context.Context) ([]*github.WorkflowRun, *time.Time, error)

func (*Client) GetState

func (c *Client) GetState() (*state.ClientState, error)

func (*Client) GetWorkflowInfo

func (c *Client) GetWorkflowInfo(ctx context.Context) (map[int64]utils.WorkflowInfo, error)

func (*Client) SaveState

func (c *Client) SaveState(state *state.ClientState) error

type GithubClient

type GithubClient struct {
	Owner      string
	Repository string
	// contains filtered or unexported fields
}

func NewGitHubClient

func NewGitHubClient(token string, owner string, repository string) GithubClient

func (*GithubClient) GetQueuedJobs

func (c *GithubClient) GetQueuedJobs(ctx context.Context) ([]*github.WorkflowRun, error)

func (*GithubClient) GetRemainingCreditsForToken

func (c *GithubClient) GetRemainingCreditsForToken(ctx context.Context) (string, string, int, error)

func (*GithubClient) GetWorkflowData

func (c *GithubClient) GetWorkflowData(ctx context.Context) (*map[int64]utils.WorkflowInfo, error)

type IClient

type IClient interface {
	GetQueuedJobs(ctx context.Context) (int, error)
	GetState() (*state.ClientState, error)
	SaveState(state *state.ClientState) error
}

type IStatelessClient

type IStatelessClient interface {
	GetQueuedJobs(ctx context.Context) ([]*github.WorkflowRun, error)
	GetRemainingCreditsForToken(ctx context.Context) (string, string, int, error)
	//TODO: Rename to GetWorkflowInfo
	GetWorkflowData(ctx context.Context) (*map[int64]utils.WorkflowInfo, error)
}

type Status

type Status int8

const (
	Unset Status = iota
	Valid
	Errored
)