grpc

Documentation

Index

• func Run(cfg *ServerConfig) error
• type BootService
  • func NewBootService(cfg *ServerConfig, eventService *EventService) *BootService
  • func (b *BootService) AbortReinstall(ctx context.Context, req *v1.BootServiceAbortReinstallRequest) (*v1.BootServiceAbortReinstallResponse, error)
  • func (b *BootService) Boot(ctx context.Context, req *v1.BootServiceBootRequest) (*v1.BootServiceBootResponse, error)
  • func (b *BootService) Dhcp(ctx context.Context, req *v1.BootServiceDhcpRequest) (*v1.BootServiceDhcpResponse, error)
  • func (b *BootService) Register(ctx context.Context, req *v1.BootServiceRegisterRequest) (*v1.BootServiceRegisterResponse, error)
  • func (b *BootService) Report(ctx context.Context, req *v1.BootServiceReportRequest) (*v1.BootServiceReportResponse, error)
  • func (b *BootService) SuperUserPassword(ctx context.Context, req *v1.BootServiceSuperUserPasswordRequest) (*v1.BootServiceSuperUserPasswordResponse, error)
  • func (b *BootService) Wait(req *v1.BootServiceWaitRequest, srv v1.BootService_WaitServer) error
• type EventService
  • func NewEventService(cfg *ServerConfig) *EventService
  • func (e *EventService) Send(ctx context.Context, req *v1.EventServiceSendRequest) (*v1.EventServiceSendResponse, error)
• type ServerConfig

Functions

func Run

func Run(cfg *ServerConfig) error

Types

type BootService

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

func NewBootService

func NewBootService(cfg *ServerConfig, eventService *EventService) *BootService

func (*BootService) AbortReinstall

func (b *BootService) AbortReinstall(ctx context.Context, req *v1.BootServiceAbortReinstallRequest) (*v1.BootServiceAbortReinstallResponse, error)

func (*BootService) Boot

func (b *BootService) Boot(ctx context.Context, req *v1.BootServiceBootRequest) (*v1.BootServiceBootResponse, error)

func (*BootService) Dhcp

func (b *BootService) Dhcp(ctx context.Context, req *v1.BootServiceDhcpRequest) (*v1.BootServiceDhcpResponse, error)

func (*BootService) Register

func (b *BootService) Register(ctx context.Context, req *v1.BootServiceRegisterRequest) (*v1.BootServiceRegisterResponse, error)

func (*BootService) Report

func (b *BootService) Report(ctx context.Context, req *v1.BootServiceReportRequest) (*v1.BootServiceReportResponse, error)

func (*BootService) SuperUserPassword

func (b *BootService) SuperUserPassword(ctx context.Context, req *v1.BootServiceSuperUserPasswordRequest) (*v1.BootServiceSuperUserPasswordResponse, error)

func (*BootService) Wait

func (b *BootService) Wait(req *v1.BootServiceWaitRequest, srv v1.BootService_WaitServer) error

type EventService

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

func NewEventService

func NewEventService(cfg *ServerConfig) *EventService

func (*EventService) Send

func (e *EventService) Send(ctx context.Context, req *v1.EventServiceSendRequest) (*v1.EventServiceSendResponse, error)

type ServerConfig

type ServerConfig struct {
	Context                  context.Context
	Publisher                bus.Publisher
	Consumer                 *bus.Consumer
	Store                    *datastore.RethinkStore
	Logger                   *slog.Logger
	GrpcPort                 int
	TlsEnabled               bool
	CaCertFile               string
	ServerCertFile           string
	ServerKeyFile            string
	ResponseInterval         time.Duration
	CheckInterval            time.Duration
	BMCSuperUserPasswordFile string
	Auditing                 auditing.Auditing
	IPMISuperUser            metal.MachineIPMISuperUser
	// contains filtered or unexported fields
}