dryad

Documentation

Index

• func RegisterDryadService(server *rpc.Server, impl Dryad) error
• type ClientManager
• type DryadClient
  • func DialDryadClient(addr string) (*DryadClient, error)
  • func NewDryadClient(client *rpc.Client) *DryadClient
  • func (_c *DryadClient) Close() error
  • func (_c *DryadClient) Create(addr *net.TCPAddr) error
  • func (_c *DryadClient) Healthcheck() (err error)
  • func (_c *DryadClient) Prepare(key *ssh.PublicKey) (err error)
  • func (_c *DryadClient) PutInMaintenance(msg string) (err error)
• type DryadHealthcheckRequest
• type DryadHealthcheckResponse
• type DryadPrepareRequest
• type DryadPrepareResponse
• type DryadPutInMaintenanceRequest
• type DryadPutInMaintenanceResponse
• type DryadService
  • func NewDryadService(impl Dryad) *DryadService
  • func (s *DryadService) Healthcheck(request *DryadHealthcheckRequest, response *DryadHealthcheckResponse) (err error)
  • func (s *DryadService) Prepare(request *DryadPrepareRequest, response *DryadPrepareResponse) (err error)
  • func (s *DryadService) PutInMaintenance(request *DryadPutInMaintenanceRequest, response *DryadPutInMaintenanceResponse) (err error)

Functions

func RegisterDryadService

func RegisterDryadService(server *rpc.Server, impl Dryad) error

RegisterDryadService registers impl in server.

Types

type ClientManager

type ClientManager interface {
	boruta.Dryad
	// Create creates a new RPC client.
	Create(*net.TCPAddr) error
	// Close shuts down RPC client connection.
	Close() error
}

ClientManager defines API for managing client RPC calls to Dryad.

type DryadClient

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

DryadClient is generated client for Dryad interface.

func DialDryadClient

func DialDryadClient(addr string) (*DryadClient, error)

DialDryadClient connects to addr and creates a new DryadClient instance.

func NewDryadClient

func NewDryadClient(client *rpc.Client) *DryadClient

NewDryadClient creates a new DryadClient instance.

func (*DryadClient) Close

func (_c *DryadClient) Close() error

Close terminates the connection.

func (*DryadClient) Create

func (_c *DryadClient) Create(addr *net.TCPAddr) error

Create sets up new TCP dialled RPC client in DryadClient structure. The Create function implements ClientManager interface.

func (*DryadClient) Healthcheck

func (_c *DryadClient) Healthcheck() (err error)

Healthcheck is part of implementation of Dryad calling corresponding method on RPC server.

func (*DryadClient) Prepare

func (_c *DryadClient) Prepare(key *ssh.PublicKey) (err error)

Prepare is part of implementation of Dryad calling corresponding method on RPC server.

func (*DryadClient) PutInMaintenance

func (_c *DryadClient) PutInMaintenance(msg string) (err error)

PutInMaintenance is part of implementation of Dryad calling corresponding method on RPC server.

type DryadHealthcheckRequest

type DryadHealthcheckRequest struct {
}

DryadHealthcheckRequest is a helper structure for Healthcheck method.

type DryadHealthcheckResponse

type DryadHealthcheckResponse struct {
}

DryadHealthcheckResponse is a helper structure for Healthcheck method.

type DryadPrepareRequest

type DryadPrepareRequest struct {
	Key *ssh.PublicKey
}

DryadPrepareRequest is a helper structure for Prepare method.

type DryadPrepareResponse

type DryadPrepareResponse struct {
}

DryadPrepareResponse is a helper structure for Prepare method.

type DryadPutInMaintenanceRequest

type DryadPutInMaintenanceRequest struct {
	Msg string
}

DryadPutInMaintenanceRequest is a helper structure for PutInMaintenance method.

type DryadPutInMaintenanceResponse

type DryadPutInMaintenanceResponse struct {
}

DryadPutInMaintenanceResponse is a helper structure for PutInMaintenance method.

type DryadService

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

DryadService is generated service for Dryad interface.

func NewDryadService

func NewDryadService(impl Dryad) *DryadService

NewDryadService creates a new DryadService instance.

func (*DryadService) Healthcheck

func (s *DryadService) Healthcheck(request *DryadHealthcheckRequest, response *DryadHealthcheckResponse) (err error)

Healthcheck is RPC implementation of Healthcheck calling it.

func (*DryadService) Prepare

func (s *DryadService) Prepare(request *DryadPrepareRequest, response *DryadPrepareResponse) (err error)

Prepare is RPC implementation of Prepare calling it.

func (*DryadService) PutInMaintenance

func (s *DryadService) PutInMaintenance(request *DryadPutInMaintenanceRequest, response *DryadPutInMaintenanceResponse) (err error)

PutInMaintenance is RPC implementation of PutInMaintenance calling it.