assets

Documentation

Index

• func AmazonSecret(bucket string, id string, secret string, token string, region string) *api.Secret
• func EtcdRc(hostPath string) *api.ReplicationController
• func EtcdService() *api.Service
• func GoogleSecret(bucket string) *api.Secret
• func InitJob(version string) *extensions.Job
• func PachdRc(shards uint64, backend backend, hostPath string, version string) *api.ReplicationController
• func PachdService() *api.Service
• func RethinkRc(backend backend, volume string, hostPath string) *api.ReplicationController
• func RethinkService() *api.Service
• func RethinkVolume(backend backend, name string, size int) *api.PersistentVolume
• func RethinkVolumeClaim(size int) *api.PersistentVolumeClaim
• func ServiceAccount() *api.ServiceAccount
• func WriteAmazonAssets(w io.Writer, shards uint64, bucket string, id string, secret string, ...)
• func WriteAssets(w io.Writer, shards uint64, backend backend, volumeName string, volumeSize int, ...)
• func WriteGoogleAssets(w io.Writer, shards uint64, bucket string, volumeName string, volumeSize int, ...)
• func WriteLocalAssets(w io.Writer, shards uint64, hostPath string, version string)

Functions

func AmazonSecret

func AmazonSecret(bucket string, id string, secret string, token string, region string) *api.Secret

AmazonSecret creates an amazon secret with the following parameters:

bucket - S3 bucket name
id     - AWS access key id
secret - AWS secret access key
token  - AWS access token
region - AWS region

func EtcdRc

func EtcdRc(hostPath string) *api.ReplicationController

EtcdRc returns an etcd replication controller.

func EtcdService

func EtcdService() *api.Service

EtcdService returns an etcd service.

func GoogleSecret

func GoogleSecret(bucket string) *api.Secret

GoogleSecret creates a google secret with a bucket name.

func InitJob

func InitJob(version string) *extensions.Job

InitJob returns a pachd-init job.

func PachdRc

func PachdRc(shards uint64, backend backend, hostPath string, version string) *api.ReplicationController

PachdRc returns a pachd replication controller.

func PachdService

func PachdService() *api.Service

PachdService returns a pachd service.

func RethinkRc

func RethinkRc(backend backend, volume string, hostPath string) *api.ReplicationController

RethinkRc returns a rethinkdb replication controller.

func RethinkService

func RethinkService() *api.Service

RethinkService returns a rethinkdb service.

func RethinkVolume

func RethinkVolume(backend backend, name string, size int) *api.PersistentVolume

RethinkVolume creates a persistent volume with a backend (local, amazon, google), a name, and a size in gigabytes.

func RethinkVolumeClaim

func RethinkVolumeClaim(size int) *api.PersistentVolumeClaim

RethinkVolumeClaim creates a persistent volume claim with a size in gigabytes.

func ServiceAccount

func ServiceAccount() *api.ServiceAccount

ServiceAccount returns a kubernetes service account for use with Pachyderm.

func WriteAmazonAssets

func WriteAmazonAssets(w io.Writer, shards uint64, bucket string, id string, secret string, token string,
	region string, volumeName string, volumeSize int, version string)

WriteAmazonAssets writes assets to an amazon backend.

func WriteAssets

func WriteAssets(w io.Writer, shards uint64, backend backend,
	volumeName string, volumeSize int, hostPath string, version string)

WriteAssets creates the assets in a dir. It expects dir to already exist.

func WriteGoogleAssets

func WriteGoogleAssets(w io.Writer, shards uint64, bucket string,
	volumeName string, volumeSize int, version string)

WriteGoogleAssets writes assets to a google backend.

func WriteLocalAssets

func WriteLocalAssets(w io.Writer, shards uint64, hostPath string, version string)

WriteLocalAssets writes assets to a local backend.