client

package module

v0.0.0-...-4a80e2f Latest Latest Go to latest Published: Jun 7, 2019 License: NCSA Imports: 52 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rai-project/client

Links

Open Source Insights

README ¶

client

RAI client logic

Documentation ¶

Index ¶

Variables
func FindTeamName(uname string) (string, error)
type Client
- func New(opts ...Option) (*Client, error)
type Fa2017Ece408Team
- func (Fa2017Ece408Team) TableName() string
type Fa2017Ece408TeamCollection
- func NewFa2017Ece408TeamCollection(db database.Database) (*Fa2017Ece408TeamCollection, error)
type Fa2017Ece408Teams
type Option
type Options
type Team
type ValidationError
- func (v *ValidationError) Error() string

Constants ¶

This section is empty.

Variables ¶

View Source

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

Config ...

View Source

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 (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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

README ¶

client

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func FindTeamName ¶

Types ¶

type Client ¶

func New ¶

func (*Client) Authenticate ¶

func (*Client) Connect ¶

func (*Client) Disconnect ¶

func (*Client) JobQueueName ¶

func (*Client) Publish ¶

func (*Client) RecordJob ¶

func (*Client) Subscribe ¶

func (*Client) Upload ¶

func (*Client) Validate ¶

func (*Client) Wait ¶

type Fa2017Ece408Team ¶

func (Fa2017Ece408Team) TableName ¶

type Fa2017Ece408TeamCollection ¶

func NewFa2017Ece408TeamCollection ¶

type Fa2017Ece408Teams ¶

type Option ¶

func BuildFileBaseName ¶

func BuildFilePath ¶

func Directory ¶

func DisableRatelimit ¶

func JobQueueName ¶

func OutputDirectory ¶

func ProfilePath ¶

func Ratelimit ¶

func ServerArch ¶

func Stderr ¶

func Stdout ¶

type Options ¶

type Team ¶

type ValidationError ¶

func (*ValidationError) Error ¶

Source Files ¶