rpc

package

v0.2.0 Latest Latest Go to latest Published: Jul 27, 2020 License: MPL-2.0 Imports: 17 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Option func(*RPC)

func WithLogger(logger *logrus.Logger) Option

type RPC struct {
	api.UnimplementedCirrusCIServiceServer
	// contains filtered or unexported fields
}

func New(build *build.Build, opts ...Option) *RPC

func (r *RPC) ClientSecret() string

func (r *RPC) Endpoint() string

Endpoint returns RPC server address suitable for use in agent's "-api-endpoint" flag.

func (r *RPC) Heartbeat(ctx context.Context, req *api.HeartbeatRequest) (*api.HeartbeatResponse, error)

func (r *RPC) InitialCommands(
	ctx context.Context,
	req *api.InitialCommandsRequest,
) (*api.CommandsResponse, error)

func (r *RPC) ReportAgentError(ctx context.Context, req *api.ReportAgentProblemRequest) (*empty.Empty, error)

func (r *RPC) ReportAgentSignal(ctx context.Context, req *api.ReportAgentSignalRequest) (*empty.Empty, error)

func (r *RPC) ReportAgentWarning(ctx context.Context, req *api.ReportAgentProblemRequest) (*empty.Empty, error)

func (r *RPC) ReportSingleCommand(
	ctx context.Context,
	req *api.ReportSingleCommandRequest,
) (*api.ReportSingleCommandResponse, error)

func (r *RPC) ServerSecret() string

func (r *RPC) Start()

Start creates the listener and starts RPC server in a separate goroutine.

func (r *RPC) Stop()

Stop gracefully stops the RPC server.

func (r *RPC) StreamLogs(stream api.CirrusCIService_StreamLogsServer) error