bigmachine

package module

Go to main page

Versions in this module

v0

v0.5.8

Jul 15, 2020

v0.5.7

Jun 24, 2020

v0.5.6

Apr 7, 2020

Changes in this version

type Supervisor

+ func (s *Supervisor) GetBinary(ctx context.Context, _ struct{}, rc *io.ReadCloser) error

+ func (s *Supervisor) Setbinary(ctx context.Context, binary io.Reader, _ *struct{}) error

+ func (s *Supervisor) Shutdown(ctx context.Context, req shutdownRequest, _ *struct{}) error

type System

+ Event func(typ string, fieldPairs ...interface{})

v0.5.5

Oct 23, 2019

Changes in this version

+ func Init()

+ type Option func(b *B)

+ func Name(name string) Option

v0.5.4

Oct 16, 2019

v0.5.3

Oct 11, 2019

v0.5.2

Oct 10, 2019

v0.5.1

Oct 10, 2019

v0.5.0

Oct 7, 2019

Changes in this version

+ const RpcPrefix

+ func Bootstrap()

+ func RegisterSystem(name string, system System)

+ type B struct

+ func Start(system System) *B

+ func (b *B) Dial(ctx context.Context, addr string) (*Machine, error)

+ func (b *B) HandleDebug(mux *http.ServeMux)

+ func (b *B) HandleDebugPrefix(prefix string, mux *http.ServeMux)

+ func (b *B) IsDriver() bool

+ func (b *B) Machines() []*Machine

+ func (b *B) Shutdown()

+ func (b *B) Start(ctx context.Context, n int, params ...Param) ([]*Machine, error)

+ func (b *B) System() System

+ type DiskInfo struct

+ Usage disk.UsageStat

+ type Environ []string

+ type Expvar struct

+ Key string

+ Value string

+ type Expvars []Expvar

+ func (e Expvars) MarshalJSON() ([]byte, error)

+ type Info struct

+ Digest digest.Digest

+ Goarch string

+ Goos string

+ func LocalInfo() Info

+ type LoadInfo struct

+ Averages load.AvgStat

+ type Machine struct

+ Addr string

+ Maxprocs int

+ NoExec bool

+ func (m *Machine) Call(ctx context.Context, serviceMethod string, arg, reply interface{}) error

+ func (m *Machine) Cancel()

+ func (m *Machine) DiskInfo(ctx context.Context) (info DiskInfo, err error)

+ func (m *Machine) Err() error

+ func (m *Machine) Hostname() string

+ func (m *Machine) KeepaliveReplyTimes() []time.Duration

+ func (m *Machine) LoadInfo(ctx context.Context) (info LoadInfo, err error)

+ func (m *Machine) MemInfo(ctx context.Context, readMemStats bool) (info MemInfo, err error)

+ func (m *Machine) NextKeepalive() time.Time

+ func (m *Machine) Owned() bool

+ func (m *Machine) RetryCall(ctx context.Context, serviceMethod string, arg, reply interface{}) error

+ func (m *Machine) State() State

+ func (m *Machine) Wait(state State) <-chan struct{}

+ type MemInfo struct

+ Runtime runtime.MemStats

+ System mem.VirtualMemoryStat

+ type Param interface

+ type Services map[string]interface

+ type State int32

+ const Running

+ const Starting

+ const Stopped

+ const Unstarted

+ func (m State) String() string

+ type Supervisor struct

+ func StartSupervisor(ctx context.Context, b *B, system System, server *rpc.Server) *Supervisor

+ func (s *Supervisor) CPUProfile(ctx context.Context, dur time.Duration, prof *io.ReadCloser) error

+ func (s *Supervisor) DiskInfo(ctx context.Context, _ struct{}, info *DiskInfo) error

+ func (s *Supervisor) Exec(ctx context.Context, exec io.Reader, _ *struct{}) error

+ func (s *Supervisor) Expvars(ctx context.Context, _ struct{}, vars *Expvars) error

+ func (s *Supervisor) Getpid(ctx context.Context, _ struct{}, pid *int) error

+ func (s *Supervisor) Info(ctx context.Context, _ struct{}, info *Info) error

+ func (s *Supervisor) Keepalive(ctx context.Context, next time.Duration, reply *keepaliveReply) error

+ func (s *Supervisor) LoadInfo(ctx context.Context, _ struct{}, info *LoadInfo) error

+ func (s *Supervisor) MemInfo(ctx context.Context, readMemStats bool, info *MemInfo) error

+ func (s *Supervisor) Ping(ctx context.Context, seq int, replyseq *int) error

+ func (s *Supervisor) Profile(ctx context.Context, req profileRequest, prof *io.ReadCloser) error

+ func (s *Supervisor) Profiles(ctx context.Context, _ struct{}, profiles *[]profileStat) error

+ func (s *Supervisor) Register(ctx context.Context, svc service, _ *struct{}) error

+ func (s *Supervisor) Setargs(ctx context.Context, args []string, _ *struct{}) error

+ func (s *Supervisor) Setenv(ctx context.Context, env []string, _ *struct{}) error

+ type System interface

+ Exit func(int)

+ HTTPClient func() *http.Client

+ Init func(*B) error

+ KeepaliveConfig func() (period, timeout, rpcTimeout time.Duration)

+ ListenAndServe func(addr string, handle http.Handler) error

+ Main func() error

+ Maxprocs func() int

+ Name func() string

+ Read func(ctx context.Context, m *Machine, filename string) (io.Reader, error)

+ Shutdown func()

+ Start func(ctx context.Context, n int) ([]*Machine, error)

+ Tail func(ctx context.Context, m *Machine) (io.Reader, error)

+ var Local System = new(localSystem)

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