transcoder

Documentation

Index

• Variables
• func ExecuteCli()
• type Client
  • func NewClient(serverAddr string, maxConcurrentJobs int64) *Client
  • func (c *Client) JoinCluster(ctx context.Context) error

Variables

var (
	ErrConnectionFailed     = errors.New("couldn't connect to distributor server")
	ErrCouldNotJoinCluster  = errors.New("couldn't join the transcoding cluster")
	ErrCouldNotUploadResult = errors.New("couldn't upload results to the host server")
)

Functions

func ExecuteCli

func ExecuteCli()

Types

type Client

type Client struct {
	ServerAddr        string
	MaxConcurrentJobs int64
	// contains filtered or unexported fields
}

func NewClient

func NewClient(serverAddr string, maxConcurrentJobs int64) *Client

func (*Client) JoinCluster

func (c *Client) JoinCluster(ctx context.Context) error