dataflow.micro.go

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

/*
Package dataflow is a generated protocol buffer package.

It is generated from these files:
	dataflow.proto

It has these top-level messages:
	Schedule
	Policy
	GetPolicyRequest
	GetPolicyResponse
	ListPolicyRequest
	ListPolicyResponse
	CreatePolicyRequest
	CreatePolicyResponse
	UpdatePolicyRequest
	UpdatePolicyResponse
	DeletePolicyRequest
	DeletePolicyResponse
	KV
	Filter
	Connector
	Plan
	CreatePlanRequest
	CreatePlanResponse
	GetPlanRequest
	GetPlanResponse
	ListPlanRequest
	ListPlanResponse
	UpdatePlanRequest
	UpdatePlanResponse
	DeletePlanRequest
	DeletePlanResponse
	RunPlanRequest
	RunPlanResponse
	Job
	GetJobRequest
	GetJobResponse
	ListJobRequest
	ListJobResponse
*/
package dataflow

import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"

import (
	client "github.com/micro/go-micro/client"
	server "github.com/micro/go-micro/server"
	context "context"
)

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

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package

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

// Client API for DataFlow service

type DataFlowService interface {
	GetPolicy(ctx context.Context, in *GetPolicyRequest, opts ...client.CallOption) (*GetPolicyResponse, error)
	ListPolicy(ctx context.Context, in *ListPolicyRequest, opts ...client.CallOption) (*ListPolicyResponse, error)
	CreatePolicy(ctx context.Context, in *CreatePolicyRequest, opts ...client.CallOption) (*CreatePolicyResponse, error)
	UpdatePolicy(ctx context.Context, in *UpdatePolicyRequest, opts ...client.CallOption) (*UpdatePolicyResponse, error)
	DeletePolicy(ctx context.Context, in *DeletePolicyRequest, opts ...client.CallOption) (*DeletePolicyResponse, error)
	GetPlan(ctx context.Context, in *GetPlanRequest, opts ...client.CallOption) (*GetPlanResponse, error)
	ListPlan(ctx context.Context, in *ListPlanRequest, opts ...client.CallOption) (*ListPlanResponse, error)
	CreatePlan(ctx context.Context, in *CreatePlanRequest, opts ...client.CallOption) (*CreatePlanResponse, error)
	UpdatePlan(ctx context.Context, in *UpdatePlanRequest, opts ...client.CallOption) (*UpdatePlanResponse, error)
	DeletePlan(ctx context.Context, in *DeletePlanRequest, opts ...client.CallOption) (*DeletePlanResponse, error)
	GetJob(ctx context.Context, in *GetJobRequest, opts ...client.CallOption) (*GetJobResponse, error)
	ListJob(ctx context.Context, in *ListJobRequest, opts ...client.CallOption) (*ListJobResponse, error)
	RunPlan(ctx context.Context, in *RunPlanRequest, opts ...client.CallOption) (*RunPlanResponse, error)
}

type dataFlowService struct {
	c    client.Client
	name string
}

func NewDataFlowService(name string, c client.Client) DataFlowService {
	if c == nil {
		c = client.NewClient()
	}
	if len(name) == 0 {
		name = "dataflow"
	}
	return &dataFlowService{
		c:    c,
		name: name,
	}
}

func (c *dataFlowService) GetPolicy(ctx context.Context, in *GetPolicyRequest, opts ...client.CallOption) (*GetPolicyResponse, error) {
	req := c.c.NewRequest(c.name, "DataFlow.GetPolicy", in)
	out := new(GetPolicyResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataFlowService) ListPolicy(ctx context.Context, in *ListPolicyRequest, opts ...client.CallOption) (*ListPolicyResponse, error) {
	req := c.c.NewRequest(c.name, "DataFlow.ListPolicy", in)
	out := new(ListPolicyResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataFlowService) CreatePolicy(ctx context.Context, in *CreatePolicyRequest, opts ...client.CallOption) (*CreatePolicyResponse, error) {
	req := c.c.NewRequest(c.name, "DataFlow.CreatePolicy", in)
	out := new(CreatePolicyResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataFlowService) UpdatePolicy(ctx context.Context, in *UpdatePolicyRequest, opts ...client.CallOption) (*UpdatePolicyResponse, error) {
	req := c.c.NewRequest(c.name, "DataFlow.UpdatePolicy", in)
	out := new(UpdatePolicyResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataFlowService) DeletePolicy(ctx context.Context, in *DeletePolicyRequest, opts ...client.CallOption) (*DeletePolicyResponse, error) {
	req := c.c.NewRequest(c.name, "DataFlow.DeletePolicy", in)
	out := new(DeletePolicyResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataFlowService) GetPlan(ctx context.Context, in *GetPlanRequest, opts ...client.CallOption) (*GetPlanResponse, error) {
	req := c.c.NewRequest(c.name, "DataFlow.GetPlan", in)
	out := new(GetPlanResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataFlowService) ListPlan(ctx context.Context, in *ListPlanRequest, opts ...client.CallOption) (*ListPlanResponse, error) {
	req := c.c.NewRequest(c.name, "DataFlow.ListPlan", in)
	out := new(ListPlanResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataFlowService) CreatePlan(ctx context.Context, in *CreatePlanRequest, opts ...client.CallOption) (*CreatePlanResponse, error) {
	req := c.c.NewRequest(c.name, "DataFlow.CreatePlan", in)
	out := new(CreatePlanResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataFlowService) UpdatePlan(ctx context.Context, in *UpdatePlanRequest, opts ...client.CallOption) (*UpdatePlanResponse, error) {
	req := c.c.NewRequest(c.name, "DataFlow.UpdatePlan", in)
	out := new(UpdatePlanResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataFlowService) DeletePlan(ctx context.Context, in *DeletePlanRequest, opts ...client.CallOption) (*DeletePlanResponse, error) {
	req := c.c.NewRequest(c.name, "DataFlow.DeletePlan", in)
	out := new(DeletePlanResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataFlowService) GetJob(ctx context.Context, in *GetJobRequest, opts ...client.CallOption) (*GetJobResponse, error) {
	req := c.c.NewRequest(c.name, "DataFlow.GetJob", in)
	out := new(GetJobResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataFlowService) ListJob(ctx context.Context, in *ListJobRequest, opts ...client.CallOption) (*ListJobResponse, error) {
	req := c.c.NewRequest(c.name, "DataFlow.ListJob", in)
	out := new(ListJobResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataFlowService) RunPlan(ctx context.Context, in *RunPlanRequest, opts ...client.CallOption) (*RunPlanResponse, error) {
	req := c.c.NewRequest(c.name, "DataFlow.RunPlan", in)
	out := new(RunPlanResponse)
	err := c.c.Call(ctx, req, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// Server API for DataFlow service

type DataFlowHandler interface {
	GetPolicy(context.Context, *GetPolicyRequest, *GetPolicyResponse) error
	ListPolicy(context.Context, *ListPolicyRequest, *ListPolicyResponse) error
	CreatePolicy(context.Context, *CreatePolicyRequest, *CreatePolicyResponse) error
	UpdatePolicy(context.Context, *UpdatePolicyRequest, *UpdatePolicyResponse) error
	DeletePolicy(context.Context, *DeletePolicyRequest, *DeletePolicyResponse) error
	GetPlan(context.Context, *GetPlanRequest, *GetPlanResponse) error
	ListPlan(context.Context, *ListPlanRequest, *ListPlanResponse) error
	CreatePlan(context.Context, *CreatePlanRequest, *CreatePlanResponse) error
	UpdatePlan(context.Context, *UpdatePlanRequest, *UpdatePlanResponse) error
	DeletePlan(context.Context, *DeletePlanRequest, *DeletePlanResponse) error
	GetJob(context.Context, *GetJobRequest, *GetJobResponse) error
	ListJob(context.Context, *ListJobRequest, *ListJobResponse) error
	RunPlan(context.Context, *RunPlanRequest, *RunPlanResponse) error
}

func RegisterDataFlowHandler(s server.Server, hdlr DataFlowHandler, opts ...server.HandlerOption) error {
	type dataFlow interface {
		GetPolicy(ctx context.Context, in *GetPolicyRequest, out *GetPolicyResponse) error
		ListPolicy(ctx context.Context, in *ListPolicyRequest, out *ListPolicyResponse) error
		CreatePolicy(ctx context.Context, in *CreatePolicyRequest, out *CreatePolicyResponse) error
		UpdatePolicy(ctx context.Context, in *UpdatePolicyRequest, out *UpdatePolicyResponse) error
		DeletePolicy(ctx context.Context, in *DeletePolicyRequest, out *DeletePolicyResponse) error
		GetPlan(ctx context.Context, in *GetPlanRequest, out *GetPlanResponse) error
		ListPlan(ctx context.Context, in *ListPlanRequest, out *ListPlanResponse) error
		CreatePlan(ctx context.Context, in *CreatePlanRequest, out *CreatePlanResponse) error
		UpdatePlan(ctx context.Context, in *UpdatePlanRequest, out *UpdatePlanResponse) error
		DeletePlan(ctx context.Context, in *DeletePlanRequest, out *DeletePlanResponse) error
		GetJob(ctx context.Context, in *GetJobRequest, out *GetJobResponse) error
		ListJob(ctx context.Context, in *ListJobRequest, out *ListJobResponse) error
		RunPlan(ctx context.Context, in *RunPlanRequest, out *RunPlanResponse) error
	}
	type DataFlow struct {
		dataFlow
	}
	h := &dataFlowHandler{hdlr}
	return s.Handle(s.NewHandler(&DataFlow{h}, opts...))
}

type dataFlowHandler struct {
	DataFlowHandler
}

func (h *dataFlowHandler) GetPolicy(ctx context.Context, in *GetPolicyRequest, out *GetPolicyResponse) error {
	return h.DataFlowHandler.GetPolicy(ctx, in, out)
}

func (h *dataFlowHandler) ListPolicy(ctx context.Context, in *ListPolicyRequest, out *ListPolicyResponse) error {
	return h.DataFlowHandler.ListPolicy(ctx, in, out)
}

func (h *dataFlowHandler) CreatePolicy(ctx context.Context, in *CreatePolicyRequest, out *CreatePolicyResponse) error {
	return h.DataFlowHandler.CreatePolicy(ctx, in, out)
}

func (h *dataFlowHandler) UpdatePolicy(ctx context.Context, in *UpdatePolicyRequest, out *UpdatePolicyResponse) error {
	return h.DataFlowHandler.UpdatePolicy(ctx, in, out)
}

func (h *dataFlowHandler) DeletePolicy(ctx context.Context, in *DeletePolicyRequest, out *DeletePolicyResponse) error {
	return h.DataFlowHandler.DeletePolicy(ctx, in, out)
}

func (h *dataFlowHandler) GetPlan(ctx context.Context, in *GetPlanRequest, out *GetPlanResponse) error {
	return h.DataFlowHandler.GetPlan(ctx, in, out)
}

func (h *dataFlowHandler) ListPlan(ctx context.Context, in *ListPlanRequest, out *ListPlanResponse) error {
	return h.DataFlowHandler.ListPlan(ctx, in, out)
}

func (h *dataFlowHandler) CreatePlan(ctx context.Context, in *CreatePlanRequest, out *CreatePlanResponse) error {
	return h.DataFlowHandler.CreatePlan(ctx, in, out)
}

func (h *dataFlowHandler) UpdatePlan(ctx context.Context, in *UpdatePlanRequest, out *UpdatePlanResponse) error {
	return h.DataFlowHandler.UpdatePlan(ctx, in, out)
}

func (h *dataFlowHandler) DeletePlan(ctx context.Context, in *DeletePlanRequest, out *DeletePlanResponse) error {
	return h.DataFlowHandler.DeletePlan(ctx, in, out)
}

func (h *dataFlowHandler) GetJob(ctx context.Context, in *GetJobRequest, out *GetJobResponse) error {
	return h.DataFlowHandler.GetJob(ctx, in, out)
}

func (h *dataFlowHandler) ListJob(ctx context.Context, in *ListJobRequest, out *ListJobResponse) error {
	return h.DataFlowHandler.ListJob(ctx, in, out)
}

func (h *dataFlowHandler) RunPlan(ctx context.Context, in *RunPlanRequest, out *RunPlanResponse) error {
	return h.DataFlowHandler.RunPlan(ctx, in, out)
}