k8s-service/proto/cronjob.pb.micro.go

// Code generated by protoc-gen-micro. DO NOT EDIT.
// source: proto/cronjob.proto

package kubernetes_service

import (
	fmt "fmt"
	proto "google.golang.org/protobuf/proto"
	math "math"
)

import (
	context "context"
	api "go-micro.dev/v4/api"
	client "go-micro.dev/v4/client"
	server "go-micro.dev/v4/server"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// Reference imports to suppress errors if they are not otherwise used.
var _ api.Endpoint
var _ context.Context
var _ client.Option
var _ server.Option

// Api Endpoints for CronJobService service

func NewCronJobServiceEndpoints() []*api.Endpoint {
	return []*api.Endpoint{}
}

// Client API for CronJobService service

type CronJobService interface {
	GetCronJobList(ctx context.Context, in *GetCronJobListRequest, opts ...client.CallOption) (*GetCronJobListResponse, error)
	GetCronJob(ctx context.Context, in *GetCronJobRequest, opts ...client.CallOption) (*GetCronJobResponse, error)
	UpdateCronJob(ctx context.Context, in *UpdateCronJobRequest, opts ...client.CallOption) (*UpdateCronJobResponse, error)
	CreateCronJob(ctx context.Context, in *CreateCronJobRequest, opts ...client.CallOption) (*CreateCronJobResponse, error)
	DeleteCronJob(ctx context.Context, in *DeleteCronJobRequest, opts ...client.CallOption) (*DeleteCronJobResponse, error)
}

type cronJobService struct {
	c    client.Client
	name string
}

func NewCronJobService(name string, c client.Client) CronJobService {
	return &cronJobService{
		c:    c,
		name: name,
	}
}

func (c *cronJobService) GetCronJobList(ctx context.Context, in *GetCronJobListRequest, opts ...client.CallOption) (*GetCronJobListResponse, error) {
	req := c.c.NewRequest(c.name, "CronJobService.GetCronJobList", in)
	out := new(GetCronJobListResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *cronJobService) GetCronJob(ctx context.Context, in *GetCronJobRequest, opts ...client.CallOption) (*GetCronJobResponse, error) {
	req := c.c.NewRequest(c.name, "CronJobService.GetCronJob", in)
	out := new(GetCronJobResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *cronJobService) UpdateCronJob(ctx context.Context, in *UpdateCronJobRequest, opts ...client.CallOption) (*UpdateCronJobResponse, error) {
	req := c.c.NewRequest(c.name, "CronJobService.UpdateCronJob", in)
	out := new(UpdateCronJobResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *cronJobService) CreateCronJob(ctx context.Context, in *CreateCronJobRequest, opts ...client.CallOption) (*CreateCronJobResponse, error) {
	req := c.c.NewRequest(c.name, "CronJobService.CreateCronJob", in)
	out := new(CreateCronJobResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *cronJobService) DeleteCronJob(ctx context.Context, in *DeleteCronJobRequest, opts ...client.CallOption) (*DeleteCronJobResponse, error) {
	req := c.c.NewRequest(c.name, "CronJobService.DeleteCronJob", in)
	out := new(DeleteCronJobResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// Server API for CronJobService service

type CronJobServiceHandler interface {
	GetCronJobList(context.Context, *GetCronJobListRequest, *GetCronJobListResponse) error
	GetCronJob(context.Context, *GetCronJobRequest, *GetCronJobResponse) error
	UpdateCronJob(context.Context, *UpdateCronJobRequest, *UpdateCronJobResponse) error
	CreateCronJob(context.Context, *CreateCronJobRequest, *CreateCronJobResponse) error
	DeleteCronJob(context.Context, *DeleteCronJobRequest, *DeleteCronJobResponse) error
}

func RegisterCronJobServiceHandler(s server.Server, hdlr CronJobServiceHandler, opts ...server.HandlerOption) error {
	type cronJobService interface {
		GetCronJobList(ctx context.Context, in *GetCronJobListRequest, out *GetCronJobListResponse) error
		GetCronJob(ctx context.Context, in *GetCronJobRequest, out *GetCronJobResponse) error
		UpdateCronJob(ctx context.Context, in *UpdateCronJobRequest, out *UpdateCronJobResponse) error
		CreateCronJob(ctx context.Context, in *CreateCronJobRequest, out *CreateCronJobResponse) error
		DeleteCronJob(ctx context.Context, in *DeleteCronJobRequest, out *DeleteCronJobResponse) error
	}
	type CronJobService struct {
		cronJobService
	}
	h := &cronJobServiceHandler{hdlr}
	return s.Handle(s.NewHandler(&CronJobService{h}, opts...))
}

type cronJobServiceHandler struct {
	CronJobServiceHandler
}

func (h *cronJobServiceHandler) GetCronJobList(ctx context.Context, in *GetCronJobListRequest, out *GetCronJobListResponse) error {
	return h.CronJobServiceHandler.GetCronJobList(ctx, in, out)
}

func (h *cronJobServiceHandler) GetCronJob(ctx context.Context, in *GetCronJobRequest, out *GetCronJobResponse) error {
	return h.CronJobServiceHandler.GetCronJob(ctx, in, out)
}

func (h *cronJobServiceHandler) UpdateCronJob(ctx context.Context, in *UpdateCronJobRequest, out *UpdateCronJobResponse) error {
	return h.CronJobServiceHandler.UpdateCronJob(ctx, in, out)
}

func (h *cronJobServiceHandler) CreateCronJob(ctx context.Context, in *CreateCronJobRequest, out *CreateCronJobResponse) error {
	return h.CronJobServiceHandler.CreateCronJob(ctx, in, out)
}

func (h *cronJobServiceHandler) DeleteCronJob(ctx context.Context, in *DeleteCronJobRequest, out *DeleteCronJobResponse) error {
	return h.CronJobServiceHandler.DeleteCronJob(ctx, in, out)
}