service

Documentation

Index

• type Service
  • func New(config cfg.ServerConfig, runc *rc.Runc, network *nt.Network, ...) *Service
  • func (s *Service) AttachDisk(ctx context.Context, req *pb.DisksOpts) (*pb.Void, error)
  • func (s *Service) CreateDisk(ctx context.Context, req *pb.NumberParcel) (*pb.TextParcel, error)
  • func (s *Service) CreateStemcell(stream pb.CPID_CreateStemcellServer) error
  • func (s *Service) CreateVM(ctx context.Context, req *pb.CreateVMOpts) (*pb.TextParcel, error)
  • func (s *Service) DeleteDisk(ctx context.Context, req *pb.TextParcel) (*pb.Void, error)
  • func (s *Service) DeleteStemcell(ctx context.Context, req *pb.TextParcel) (*pb.Void, error)
  • func (s *Service) DeleteVM(ctx context.Context, req *pb.TextParcel) (*pb.Void, error)
  • func (s *Service) DetachDisk(ctx context.Context, req *pb.DisksOpts) (*pb.Void, error)
  • func (s *Service) HasDisk(ctx context.Context, req *pb.TextParcel) (*pb.TruthParcel, error)
  • func (s *Service) HasVM(ctx context.Context, req *pb.TextParcel) (*pb.TruthParcel, error)
  • func (s *Service) Ping(ctx context.Context, req *pb.Void) (*pb.TextParcel, error)
  • func (s *Service) Prune(ctx context.Context, req *pb.Void) (*pb.Void, error)
  • func (s *Service) StreamIn(stream pb.CPID_StreamInServer) error
  • func (s *Service) StreamOut(path *pb.TextParcel, stream pb.CPID_StreamOutServer) error

Types

type Service

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

func New

func New(config cfg.ServerConfig, runc *rc.Runc, network *nt.Network, logger *log.Logger) *Service

func (*Service) AttachDisk

func (s *Service) AttachDisk(ctx context.Context, req *pb.DisksOpts) (*pb.Void, error)

func (*Service) CreateDisk

func (s *Service) CreateDisk(ctx context.Context, req *pb.NumberParcel) (*pb.TextParcel, error)

func (*Service) CreateStemcell

func (s *Service) CreateStemcell(stream pb.CPID_CreateStemcellServer) error

func (*Service) CreateVM

func (s *Service) CreateVM(ctx context.Context, req *pb.CreateVMOpts) (*pb.TextParcel, error)

func (*Service) DeleteDisk

func (s *Service) DeleteDisk(ctx context.Context, req *pb.TextParcel) (*pb.Void, error)

func (*Service) DeleteStemcell

func (s *Service) DeleteStemcell(ctx context.Context, req *pb.TextParcel) (*pb.Void, error)

func (*Service) DeleteVM

func (s *Service) DeleteVM(ctx context.Context, req *pb.TextParcel) (*pb.Void, error)

Consider extending this method to delete all VMs depending on if the caller needs to w/o knowing vmID

func (*Service) DetachDisk

func (s *Service) DetachDisk(ctx context.Context, req *pb.DisksOpts) (*pb.Void, error)

func (*Service) HasDisk

func (s *Service) HasDisk(ctx context.Context, req *pb.TextParcel) (*pb.TruthParcel, error)

func (*Service) HasVM

func (s *Service) HasVM(ctx context.Context, req *pb.TextParcel) (*pb.TruthParcel, error)

func (*Service) Ping

func (s *Service) Ping(ctx context.Context, req *pb.Void) (*pb.TextParcel, error)

func (*Service) Prune

func (s *Service) Prune(ctx context.Context, req *pb.Void) (*pb.Void, error)

func (*Service) StreamIn

func (s *Service) StreamIn(stream pb.CPID_StreamInServer) error

func (*Service) StreamOut

func (s *Service) StreamOut(path *pb.TextParcel, stream pb.CPID_StreamOutServer) error