adapter

Documentation

Index

• Constants
• func GetServiceId(input string) string
• func GetSysctls() map[string]string
• type AppConfig
• type ContainerStatus
• type Orchestrator
  • func NewDockerSwarm(options OrchestratorOptions) (Orchestrator, error)
• type OrchestratorOptions
  • func (s OrchestratorOptions) MaxReloadTimedDelay() time.Duration
• type ReverseProxyConfig
• type Runner
• type SSLOptions
• type ServiceConfig

Constants

const CPU_SHARES = 1000000000

const DEFAULT_NGINX_CONFIG = `` /* 661-byte string literal not displayed */

const DOCKER_API_VERSION = "1.40"

const LOCAL_DRIVER = "local"

const MEGABYTE = 1024 * 1024

const NGINX_CONF = "nginx.conf"

const ORBS_BLOCKS_TARGET = "/usr/local/var/orbs"

const ORBS_LOGS_TARGET = "/opt/orbs/logs"

const PROXY_CONTAINER_NAME = "http-api-reverse-proxy"

const REXRAY_EBS_DRIVER = "rexray/ebs"

const SHARED_SIGNER_NETWORK = "signer-overlay"

const SSL_CERT = "ssl-cert"

const SSL_KEY = "ssl-key"

const VCHAINS_CONF = "vchains.conf"

Functions

func GetServiceId

func GetServiceId(input string) string

func GetSysctls

func GetSysctls() map[string]string

Types

type AppConfig

type AppConfig struct {
	KeyPair []byte
	Network []byte
	Config  []byte
}

type ContainerStatus

type ContainerStatus struct {
	Name   string
	NodeID string
	State  string
	Error  string

	Logs string

	CreatedAt time.Time
}

type Orchestrator

type Orchestrator interface {
	PullImage(ctx context.Context, imageName string) error
	Prepare(ctx context.Context, serviceConfig *ServiceConfig, appConfig *AppConfig) (Runner, error)
	RemoveContainer(ctx context.Context, containerName string) error

	PrepareService(ctx context.Context, serviceConfig *ServiceConfig, appConfig *AppConfig) (Runner, error)
	PrepareReverseProxy(ctx context.Context, config *ReverseProxyConfig) (Runner, error)

	GetOverlayNetwork(ctx context.Context, name string) (string, error)

	GetStatus(ctx context.Context) ([]*ContainerStatus, error)

	io.Closer
}

func NewDockerSwarm

func NewDockerSwarm(options OrchestratorOptions) (Orchestrator, error)

type OrchestratorOptions

type OrchestratorOptions struct {
	StorageDriver          string            `json:"storage-driver"`
	StorageOptions         map[string]string `json:"storage-options"`
	MaxReloadTimedDelayStr string            `json:"max-reload-time-delay"`
}

func (OrchestratorOptions) MaxReloadTimedDelay

func (s OrchestratorOptions) MaxReloadTimedDelay() time.Duration

type ReverseProxyConfig

type ReverseProxyConfig struct {
	NginxConfig    string
	SSLCertificate []byte
	SSLPrivateKey  []byte
}

type Runner

type Runner interface {
	Run(ctx context.Context) error
}

type SSLOptions

type SSLOptions struct {
	SSLCertificatePath string
	SSLPrivateKeyPath  string
}

type ServiceConfig

type ServiceConfig struct {
	Id            uint32
	NodeAddress   string
	ImageName     string
	ContainerName string

	// FIXME rename ports to be less vchain-specific
	HttpPort   int
	GossipPort int

	LimitedMemory  int64
	LimitedCPU     float64
	ReservedMemory int64
	ReservedCPU    float64

	BlocksVolumeSize int
	LogsVolumeSize   int
}