planner

Documentation

Index

• type PlannerService
  • func NewPlannerService(logger *zap.Logger) *PlannerService
  • func (ps *PlannerService) DetermineStrategy(ctx context.Context, in *platform.DetermineStrategyRequest) (*platform.DetermineStrategyResponse, error)
  • func (ps *PlannerService) PipelineSyncPlan(ctx context.Context, in *platform.PipelineSyncPlanRequest) (*platform.PipelineSyncPlanResponse, error)
  • func (ps *PlannerService) QuickSyncPlan(ctx context.Context, in *platform.QuickSyncPlanRequest) (*platform.QuickSyncPlanResponse, error)
  • func (a *PlannerService) Register(server *grpc.Server)

Types

type PlannerService

type PlannerService struct {
	platform.UnimplementedPlannerServiceServer

	RegexPool *regexpool.Pool
	Logger    *zap.Logger
}

func NewPlannerService

func NewPlannerService(logger *zap.Logger) *PlannerService

NewPlannerService creates a new planService.

func (*PlannerService) DetermineStrategy

func (ps *PlannerService) DetermineStrategy(ctx context.Context, in *platform.DetermineStrategyRequest) (*platform.DetermineStrategyResponse, error)

func (*PlannerService) PipelineSyncPlan

func (ps *PlannerService) PipelineSyncPlan(ctx context.Context, in *platform.PipelineSyncPlanRequest) (*platform.PipelineSyncPlanResponse, error)

func (*PlannerService) QuickSyncPlan

func (ps *PlannerService) QuickSyncPlan(ctx context.Context, in *platform.QuickSyncPlanRequest) (*platform.QuickSyncPlanResponse, error)

func (*PlannerService) Register

func (a *PlannerService) Register(server *grpc.Server)

Register registers all handling of this service into the specified gRPC server.