kdeploy_client_go

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, target string, opts ...Opt) (*Client, error)
  • func (c *Client) CreateApp(ctx context.Context, app *kdeploypb.AppConstructor) (*kdeploypb.App, error)
  • func (c *Client) DeleteApp(ctx context.Context, ref *kdeploypb.AppRef) error
  • func (c *Client) GetApp(ctx context.Context, ref *kdeploypb.AppRef) (*kdeploypb.App, error)
  • func (c *Client) Logs(ctx context.Context, ref *kdeploypb.AppRef, fn func(l *kdeploypb.Log) bool) error
  • func (c *Client) UpdateApp(ctx context.Context, app *kdeploypb.AppUpdate) (*kdeploypb.App, error)
• type Opt
  • func WithLogging(logging, logPayload bool) Opt
  • func WithMetrics(metrics bool) Opt
  • func WithTokenSource(tokenSource oauth2.TokenSource) Opt
  • func WithTransportCreds(creds credentials.TransportCredentials) Opt
• type Options

Types

type Client

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

Client is a kdeploy gRPC client

func NewClient

func NewClient(ctx context.Context, target string, opts ...Opt) (*Client, error)

NewClient creates a new gRPC kdeploy client

func (*Client) CreateApp

func (c *Client) CreateApp(ctx context.Context, app *kdeploypb.AppConstructor) (*kdeploypb.App, error)

CreateApp creates a new application

func (*Client) DeleteApp

func (c *Client) DeleteApp(ctx context.Context, ref *kdeploypb.AppRef) error

DeleteApp deletes an application by reference(name/namespace)

func (*Client) GetApp

func (c *Client) GetApp(ctx context.Context, ref *kdeploypb.AppRef) (*kdeploypb.App, error)

GetApp get an application by reference(name/namespace)

func (*Client) Logs

func (c *Client) Logs(ctx context.Context, ref *kdeploypb.AppRef, fn func(l *kdeploypb.Log) bool) error

Logs streams logs from an application until the context cancelled or the function(fn) return false

func (*Client) UpdateApp

func (c *Client) UpdateApp(ctx context.Context, app *kdeploypb.AppUpdate) (*kdeploypb.App, error)

UpdateApp updates an application - it performs a patch, not a full replace

type Opt

type Opt func(o *Options)

func WithLogging

func WithLogging(logging, logPayload bool) Opt

func WithMetrics

func WithMetrics(metrics bool) Opt

func WithTokenSource

func WithTokenSource(tokenSource oauth2.TokenSource) Opt

func WithTransportCreds

func WithTransportCreds(creds credentials.TransportCredentials) Opt

type Options

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