client

README

client

RAI client logic

Documentation

Index

• Variables
• func FindTeamName(uname string) (string, error)
• type Client
  • func New(opts ...Option) (*Client, error)
  • func (c *Client) Authenticate() error
  • func (c *Client) Connect() error
  • func (c *Client) Disconnect() error
  • func (c *Client) JobQueueName() string
  • func (c *Client) Publish() error
  • func (c *Client) RecordJob() error
  • func (c *Client) Subscribe() error
  • func (c *Client) Upload() error
  • func (c *Client) Validate() error
  • func (c *Client) Wait() error
• type Fa2017Ece408Team
  • func (Fa2017Ece408Team) TableName() string
• type Fa2017Ece408TeamCollection
  • func NewFa2017Ece408TeamCollection(db database.Database) (*Fa2017Ece408TeamCollection, error)
• type Fa2017Ece408Teams
• type Option
  • func BuildFileBaseName(d string) Option
  • func BuildFilePath(s string) Option
  • func Directory(d string) Option
  • func DisableRatelimit() Option
  • func JobQueueName(s string) Option
  • func OutputDirectory(dir string, force bool) Option
  • func ProfilePath(s string) Option
  • func Ratelimit(d time.Duration) Option
  • func ServerArch(s string) Option
  • func Stderr(s io.WriteCloser) Option
  • func Stdout(s io.WriteCloser) Option
• type Options
• type Team
• type ValidationError
  • func (v *ValidationError) Error() string

Variables

var (
	Config = &clientConfig{
		done: make(chan struct{}),
	}
)

Config ...

var (
	DefaultUploadExpiration = func() time.Time {
		return time.Now().AddDate(0, 6, 0)
	}
)

DefaultUploadExpiration ...

Functions

func FindTeamName

func FindTeamName(uname string) (string, error)

Types

type Client

type Client struct {
	ID bson.ObjectId
	// contains filtered or unexported fields
}

func New

func New(opts ...Option) (*Client, error)

New ...

func (*Client) Authenticate

func (c *Client) Authenticate() error

create an authentication token for AWS and fix the docker credientials in the job request

func (*Client) Connect

func (c *Client) Connect() error

Connect to the brokers

func (*Client) Disconnect

func (c *Client) Disconnect() error

Disconnect ...

func (*Client) JobQueueName

func (c *Client) JobQueueName() string

JobQueueName returns the job queue name from option, build file, or config in that order

func (*Client) Publish

func (c *Client) Publish() error

Publish ...

func (*Client) RecordJob

func (c *Client) RecordJob() error

func (*Client) Subscribe

func (c *Client) Subscribe() error

Subscribe ...

func (*Client) Upload

func (c *Client) Upload() error

Upload ...

func (*Client) Validate

func (c *Client) Validate() error

validation of client parameters this includes:

• authentication, roles
• run custom prevalidation steps
• existance and validity of the build spec file

func (*Client) Wait

func (c *Client) Wait() error

Wait until we are complete (got the end signal)

type Fa2017Ece408Team

type Fa2017Ece408Team struct {
	Team `bson:",inline"`
}

func (Fa2017Ece408Team) TableName

func (Fa2017Ece408Team) TableName() string

type Fa2017Ece408TeamCollection

type Fa2017Ece408TeamCollection struct {
	*mongodb.MongoTable
}

func NewFa2017Ece408TeamCollection

func NewFa2017Ece408TeamCollection(db database.Database) (*Fa2017Ece408TeamCollection, error)

type Fa2017Ece408Teams

type Fa2017Ece408Teams []Fa2017Ece408Team

type Option

type Option func(*Options)

Option ...

func BuildFileBaseName

func BuildFileBaseName(d string) Option

BuildFileBaseName ...

func BuildFilePath

func BuildFilePath(s string) Option

BuildFile ...

func Directory

func Directory(d string) Option

Directory ...

func DisableRatelimit

func DisableRatelimit() Option

DisableRatelimit ...

func JobQueueName

func JobQueueName(s string) Option

JobQueueName ...

func OutputDirectory

func OutputDirectory(dir string, force bool) Option

OutputDirectory ...

func ProfilePath

func ProfilePath(s string) Option

ProfilePath ...

func Ratelimit

func Ratelimit(d time.Duration) Option

Ratelimit ...

func ServerArch

func ServerArch(s string) Option

ServerArch ...

func Stderr

func Stderr(s io.WriteCloser) Option

Stderr ...

func Stdout

func Stdout(s io.WriteCloser) Option

Stdout ...

type Options

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

Options ...

type Team

type Team struct {
	Userid   string
	Teamname string
	Class    string
	Current  bool `bson:"current"`
}

type ValidationError

type ValidationError struct {
	Message string
}

func (*ValidationError) Error

func (v *ValidationError) Error() string