dataflow

package
v0.5.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 12, 2019 License: Apache-2.0 Imports: 6 Imported by: 8

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDataFlowHandler 

func RegisterDataFlowHandler(s server.Server, hdlr DataFlowHandler, opts ...server.HandlerOption) error

Types

type Connector 

type Connector struct {
	StorType             string   `protobuf:"bytes,1,opt,name=storType,proto3" json:"storType,omitempty"`
	BucketName           string   `protobuf:"bytes,2,opt,name=bucketName,proto3" json:"bucketName,omitempty"`
	ConnConfig           []*KV    `protobuf:"bytes,3,rep,name=connConfig,proto3" json:"connConfig,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Connector) Descriptor 

func (*Connector) Descriptor() ([]byte, []int)

func (*Connector) GetBucketName 

func (m *Connector) GetBucketName() string

func (*Connector) GetConnConfig 

func (m *Connector) GetConnConfig() []*KV

func (*Connector) GetStorType 

func (m *Connector) GetStorType() string

func (*Connector) ProtoMessage 

func (*Connector) ProtoMessage()

func (*Connector) Reset 

func (m *Connector) Reset()

func (*Connector) String 

func (m *Connector) String() string

func (*Connector) XXX_DiscardUnknown 

func (m *Connector) XXX_DiscardUnknown()

func (*Connector) XXX_Marshal 

func (m *Connector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Connector) XXX_Merge 

func (dst *Connector) XXX_Merge(src proto.Message)

func (*Connector) XXX_Size 

func (m *Connector) XXX_Size() int

func (*Connector) XXX_Unmarshal 

func (m *Connector) XXX_Unmarshal(b []byte) error

type CreatePlanRequest 

type CreatePlanRequest struct {
	Context              string   `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Plan                 *Plan    `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreatePlanRequest) Descriptor 

func (*CreatePlanRequest) Descriptor() ([]byte, []int)

func (*CreatePlanRequest) GetContext 

func (m *CreatePlanRequest) GetContext() string

func (*CreatePlanRequest) GetPlan 

func (m *CreatePlanRequest) GetPlan() *Plan

func (*CreatePlanRequest) ProtoMessage 

func (*CreatePlanRequest) ProtoMessage()

func (*CreatePlanRequest) Reset 

func (m *CreatePlanRequest) Reset()

func (*CreatePlanRequest) String 

func (m *CreatePlanRequest) String() string

func (*CreatePlanRequest) XXX_DiscardUnknown 

func (m *CreatePlanRequest) XXX_DiscardUnknown()

func (*CreatePlanRequest) XXX_Marshal 

func (m *CreatePlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreatePlanRequest) XXX_Merge 

func (dst *CreatePlanRequest) XXX_Merge(src proto.Message)

func (*CreatePlanRequest) XXX_Size 

func (m *CreatePlanRequest) XXX_Size() int

func (*CreatePlanRequest) XXX_Unmarshal 

func (m *CreatePlanRequest) XXX_Unmarshal(b []byte) error

type CreatePlanResponse 

type CreatePlanResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Plan                 *Plan    `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreatePlanResponse) Descriptor 

func (*CreatePlanResponse) Descriptor() ([]byte, []int)

func (*CreatePlanResponse) GetErr 

func (m *CreatePlanResponse) GetErr() string

func (*CreatePlanResponse) GetPlan 

func (m *CreatePlanResponse) GetPlan() *Plan

func (*CreatePlanResponse) ProtoMessage 

func (*CreatePlanResponse) ProtoMessage()

func (*CreatePlanResponse) Reset 

func (m *CreatePlanResponse) Reset()

func (*CreatePlanResponse) String 

func (m *CreatePlanResponse) String() string

func (*CreatePlanResponse) XXX_DiscardUnknown 

func (m *CreatePlanResponse) XXX_DiscardUnknown()

func (*CreatePlanResponse) XXX_Marshal 

func (m *CreatePlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreatePlanResponse) XXX_Merge 

func (dst *CreatePlanResponse) XXX_Merge(src proto.Message)

func (*CreatePlanResponse) XXX_Size 

func (m *CreatePlanResponse) XXX_Size() int

func (*CreatePlanResponse) XXX_Unmarshal 

func (m *CreatePlanResponse) XXX_Unmarshal(b []byte) error

type CreatePolicyRequest 

type CreatePolicyRequest struct {
	Context              string   `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Policy               *Policy  `protobuf:"bytes,2,opt,name=policy,proto3" json:"policy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreatePolicyRequest) Descriptor 

func (*CreatePolicyRequest) Descriptor() ([]byte, []int)

func (*CreatePolicyRequest) GetContext 

func (m *CreatePolicyRequest) GetContext() string

func (*CreatePolicyRequest) GetPolicy 

func (m *CreatePolicyRequest) GetPolicy() *Policy

func (*CreatePolicyRequest) ProtoMessage 

func (*CreatePolicyRequest) ProtoMessage()

func (*CreatePolicyRequest) Reset 

func (m *CreatePolicyRequest) Reset()

func (*CreatePolicyRequest) String 

func (m *CreatePolicyRequest) String() string

func (*CreatePolicyRequest) XXX_DiscardUnknown 

func (m *CreatePolicyRequest) XXX_DiscardUnknown()

func (*CreatePolicyRequest) XXX_Marshal 

func (m *CreatePolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreatePolicyRequest) XXX_Merge 

func (dst *CreatePolicyRequest) XXX_Merge(src proto.Message)

func (*CreatePolicyRequest) XXX_Size 

func (m *CreatePolicyRequest) XXX_Size() int

func (*CreatePolicyRequest) XXX_Unmarshal 

func (m *CreatePolicyRequest) XXX_Unmarshal(b []byte) error

type CreatePolicyResponse 

type CreatePolicyResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Policy               *Policy  `protobuf:"bytes,2,opt,name=policy,proto3" json:"policy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreatePolicyResponse) Descriptor 

func (*CreatePolicyResponse) Descriptor() ([]byte, []int)

func (*CreatePolicyResponse) GetErr 

func (m *CreatePolicyResponse) GetErr() string

func (*CreatePolicyResponse) GetPolicy 

func (m *CreatePolicyResponse) GetPolicy() *Policy

func (*CreatePolicyResponse) ProtoMessage 

func (*CreatePolicyResponse) ProtoMessage()

func (*CreatePolicyResponse) Reset 

func (m *CreatePolicyResponse) Reset()

func (*CreatePolicyResponse) String 

func (m *CreatePolicyResponse) String() string

func (*CreatePolicyResponse) XXX_DiscardUnknown 

func (m *CreatePolicyResponse) XXX_DiscardUnknown()

func (*CreatePolicyResponse) XXX_Marshal 

func (m *CreatePolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreatePolicyResponse) XXX_Merge 

func (dst *CreatePolicyResponse) XXX_Merge(src proto.Message)

func (*CreatePolicyResponse) XXX_Size 

func (m *CreatePolicyResponse) XXX_Size() int

func (*CreatePolicyResponse) XXX_Unmarshal 

func (m *CreatePolicyResponse) XXX_Unmarshal(b []byte) error

type DataFlowHandler 

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
}

type DataFlowService 

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)
}

func NewDataFlowService 

func NewDataFlowService(name string, c client.Client) DataFlowService

type DeletePlanRequest 

type DeletePlanRequest struct {
	Context              string   `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeletePlanRequest) Descriptor 

func (*DeletePlanRequest) Descriptor() ([]byte, []int)

func (*DeletePlanRequest) GetContext 

func (m *DeletePlanRequest) GetContext() string

func (*DeletePlanRequest) GetId 

func (m *DeletePlanRequest) GetId() string

func (*DeletePlanRequest) ProtoMessage 

func (*DeletePlanRequest) ProtoMessage()

func (*DeletePlanRequest) Reset 

func (m *DeletePlanRequest) Reset()

func (*DeletePlanRequest) String 

func (m *DeletePlanRequest) String() string

func (*DeletePlanRequest) XXX_DiscardUnknown 

func (m *DeletePlanRequest) XXX_DiscardUnknown()

func (*DeletePlanRequest) XXX_Marshal 

func (m *DeletePlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeletePlanRequest) XXX_Merge 

func (dst *DeletePlanRequest) XXX_Merge(src proto.Message)

func (*DeletePlanRequest) XXX_Size 

func (m *DeletePlanRequest) XXX_Size() int

func (*DeletePlanRequest) XXX_Unmarshal 

func (m *DeletePlanRequest) XXX_Unmarshal(b []byte) error

type DeletePlanResponse 

type DeletePlanResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeletePlanResponse) Descriptor 

func (*DeletePlanResponse) Descriptor() ([]byte, []int)

func (*DeletePlanResponse) GetErr 

func (m *DeletePlanResponse) GetErr() string

func (*DeletePlanResponse) ProtoMessage 

func (*DeletePlanResponse) ProtoMessage()

func (*DeletePlanResponse) Reset 

func (m *DeletePlanResponse) Reset()

func (*DeletePlanResponse) String 

func (m *DeletePlanResponse) String() string

func (*DeletePlanResponse) XXX_DiscardUnknown 

func (m *DeletePlanResponse) XXX_DiscardUnknown()

func (*DeletePlanResponse) XXX_Marshal 

func (m *DeletePlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeletePlanResponse) XXX_Merge 

func (dst *DeletePlanResponse) XXX_Merge(src proto.Message)

func (*DeletePlanResponse) XXX_Size 

func (m *DeletePlanResponse) XXX_Size() int

func (*DeletePlanResponse) XXX_Unmarshal 

func (m *DeletePlanResponse) XXX_Unmarshal(b []byte) error

type DeletePolicyRequest 

type DeletePolicyRequest struct {
	Context              string   `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeletePolicyRequest) Descriptor 

func (*DeletePolicyRequest) Descriptor() ([]byte, []int)

func (*DeletePolicyRequest) GetContext 

func (m *DeletePolicyRequest) GetContext() string

func (*DeletePolicyRequest) GetId 

func (m *DeletePolicyRequest) GetId() string

func (*DeletePolicyRequest) ProtoMessage 

func (*DeletePolicyRequest) ProtoMessage()

func (*DeletePolicyRequest) Reset 

func (m *DeletePolicyRequest) Reset()

func (*DeletePolicyRequest) String 

func (m *DeletePolicyRequest) String() string

func (*DeletePolicyRequest) XXX_DiscardUnknown 

func (m *DeletePolicyRequest) XXX_DiscardUnknown()

func (*DeletePolicyRequest) XXX_Marshal 

func (m *DeletePolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeletePolicyRequest) XXX_Merge 

func (dst *DeletePolicyRequest) XXX_Merge(src proto.Message)

func (*DeletePolicyRequest) XXX_Size 

func (m *DeletePolicyRequest) XXX_Size() int

func (*DeletePolicyRequest) XXX_Unmarshal 

func (m *DeletePolicyRequest) XXX_Unmarshal(b []byte) error

type DeletePolicyResponse 

type DeletePolicyResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeletePolicyResponse) Descriptor 

func (*DeletePolicyResponse) Descriptor() ([]byte, []int)

func (*DeletePolicyResponse) GetErr 

func (m *DeletePolicyResponse) GetErr() string

func (*DeletePolicyResponse) ProtoMessage 

func (*DeletePolicyResponse) ProtoMessage()

func (*DeletePolicyResponse) Reset 

func (m *DeletePolicyResponse) Reset()

func (*DeletePolicyResponse) String 

func (m *DeletePolicyResponse) String() string

func (*DeletePolicyResponse) XXX_DiscardUnknown 

func (m *DeletePolicyResponse) XXX_DiscardUnknown()

func (*DeletePolicyResponse) XXX_Marshal 

func (m *DeletePolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeletePolicyResponse) XXX_Merge 

func (dst *DeletePolicyResponse) XXX_Merge(src proto.Message)

func (*DeletePolicyResponse) XXX_Size 

func (m *DeletePolicyResponse) XXX_Size() int

func (*DeletePolicyResponse) XXX_Unmarshal 

func (m *DeletePolicyResponse) XXX_Unmarshal(b []byte) error

type Filter 

type Filter struct {
	Prefix               string   `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Tag                  []*KV    `protobuf:"bytes,2,rep,name=tag,proto3" json:"tag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Filter) Descriptor 

func (*Filter) Descriptor() ([]byte, []int)

func (*Filter) GetPrefix 

func (m *Filter) GetPrefix() string

func (*Filter) GetTag 

func (m *Filter) GetTag() []*KV

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) String 

func (m *Filter) String() string

func (*Filter) XXX_DiscardUnknown 

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal 

func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Filter) XXX_Merge 

func (dst *Filter) XXX_Merge(src proto.Message)

func (*Filter) XXX_Size 

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal 

func (m *Filter) XXX_Unmarshal(b []byte) error

type GetJobRequest 

type GetJobRequest struct {
	Context              string   `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetJobRequest) Descriptor 

func (*GetJobRequest) Descriptor() ([]byte, []int)

func (*GetJobRequest) GetContext 

func (m *GetJobRequest) GetContext() string

func (*GetJobRequest) GetId 

func (m *GetJobRequest) GetId() string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) Reset 

func (m *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (m *GetJobRequest) String() string

func (*GetJobRequest) XXX_DiscardUnknown 

func (m *GetJobRequest) XXX_DiscardUnknown()

func (*GetJobRequest) XXX_Marshal 

func (m *GetJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobRequest) XXX_Merge 

func (dst *GetJobRequest) XXX_Merge(src proto.Message)

func (*GetJobRequest) XXX_Size 

func (m *GetJobRequest) XXX_Size() int

func (*GetJobRequest) XXX_Unmarshal 

func (m *GetJobRequest) XXX_Unmarshal(b []byte) error

type GetJobResponse 

type GetJobResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Job                  *Job     `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetJobResponse) Descriptor 

func (*GetJobResponse) Descriptor() ([]byte, []int)

func (*GetJobResponse) GetErr 

func (m *GetJobResponse) GetErr() string

func (*GetJobResponse) GetJob 

func (m *GetJobResponse) GetJob() *Job

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) Reset 

func (m *GetJobResponse) Reset()

func (*GetJobResponse) String 

func (m *GetJobResponse) String() string

func (*GetJobResponse) XXX_DiscardUnknown 

func (m *GetJobResponse) XXX_DiscardUnknown()

func (*GetJobResponse) XXX_Marshal 

func (m *GetJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobResponse) XXX_Merge 

func (dst *GetJobResponse) XXX_Merge(src proto.Message)

func (*GetJobResponse) XXX_Size 

func (m *GetJobResponse) XXX_Size() int

func (*GetJobResponse) XXX_Unmarshal 

func (m *GetJobResponse) XXX_Unmarshal(b []byte) error

type GetPlanRequest 

type GetPlanRequest struct {
	Context              string   `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPlanRequest) Descriptor 

func (*GetPlanRequest) Descriptor() ([]byte, []int)

func (*GetPlanRequest) GetContext 

func (m *GetPlanRequest) GetContext() string

func (*GetPlanRequest) GetId 

func (m *GetPlanRequest) GetId() string

func (*GetPlanRequest) ProtoMessage 

func (*GetPlanRequest) ProtoMessage()

func (*GetPlanRequest) Reset 

func (m *GetPlanRequest) Reset()

func (*GetPlanRequest) String 

func (m *GetPlanRequest) String() string

func (*GetPlanRequest) XXX_DiscardUnknown 

func (m *GetPlanRequest) XXX_DiscardUnknown()

func (*GetPlanRequest) XXX_Marshal 

func (m *GetPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPlanRequest) XXX_Merge 

func (dst *GetPlanRequest) XXX_Merge(src proto.Message)

func (*GetPlanRequest) XXX_Size 

func (m *GetPlanRequest) XXX_Size() int

func (*GetPlanRequest) XXX_Unmarshal 

func (m *GetPlanRequest) XXX_Unmarshal(b []byte) error

type GetPlanResponse 

type GetPlanResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Plan                 *Plan    `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPlanResponse) Descriptor 

func (*GetPlanResponse) Descriptor() ([]byte, []int)

func (*GetPlanResponse) GetErr 

func (m *GetPlanResponse) GetErr() string

func (*GetPlanResponse) GetPlan 

func (m *GetPlanResponse) GetPlan() *Plan

func (*GetPlanResponse) ProtoMessage 

func (*GetPlanResponse) ProtoMessage()

func (*GetPlanResponse) Reset 

func (m *GetPlanResponse) Reset()

func (*GetPlanResponse) String 

func (m *GetPlanResponse) String() string

func (*GetPlanResponse) XXX_DiscardUnknown 

func (m *GetPlanResponse) XXX_DiscardUnknown()

func (*GetPlanResponse) XXX_Marshal 

func (m *GetPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPlanResponse) XXX_Merge 

func (dst *GetPlanResponse) XXX_Merge(src proto.Message)

func (*GetPlanResponse) XXX_Size 

func (m *GetPlanResponse) XXX_Size() int

func (*GetPlanResponse) XXX_Unmarshal 

func (m *GetPlanResponse) XXX_Unmarshal(b []byte) error

type GetPolicyRequest 

type GetPolicyRequest struct {
	Context              string   `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPolicyRequest) Descriptor 

func (*GetPolicyRequest) Descriptor() ([]byte, []int)

func (*GetPolicyRequest) GetContext 

func (m *GetPolicyRequest) GetContext() string

func (*GetPolicyRequest) GetId 

func (m *GetPolicyRequest) GetId() string

func (*GetPolicyRequest) ProtoMessage 

func (*GetPolicyRequest) ProtoMessage()

func (*GetPolicyRequest) Reset 

func (m *GetPolicyRequest) Reset()

func (*GetPolicyRequest) String 

func (m *GetPolicyRequest) String() string

func (*GetPolicyRequest) XXX_DiscardUnknown 

func (m *GetPolicyRequest) XXX_DiscardUnknown()

func (*GetPolicyRequest) XXX_Marshal 

func (m *GetPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPolicyRequest) XXX_Merge 

func (dst *GetPolicyRequest) XXX_Merge(src proto.Message)

func (*GetPolicyRequest) XXX_Size 

func (m *GetPolicyRequest) XXX_Size() int

func (*GetPolicyRequest) XXX_Unmarshal 

func (m *GetPolicyRequest) XXX_Unmarshal(b []byte) error

type GetPolicyResponse 

type GetPolicyResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Policy               *Policy  `protobuf:"bytes,2,opt,name=policy,proto3" json:"policy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPolicyResponse) Descriptor 

func (*GetPolicyResponse) Descriptor() ([]byte, []int)

func (*GetPolicyResponse) GetErr 

func (m *GetPolicyResponse) GetErr() string

func (*GetPolicyResponse) GetPolicy 

func (m *GetPolicyResponse) GetPolicy() *Policy

func (*GetPolicyResponse) ProtoMessage 

func (*GetPolicyResponse) ProtoMessage()

func (*GetPolicyResponse) Reset 

func (m *GetPolicyResponse) Reset()

func (*GetPolicyResponse) String 

func (m *GetPolicyResponse) String() string

func (*GetPolicyResponse) XXX_DiscardUnknown 

func (m *GetPolicyResponse) XXX_DiscardUnknown()

func (*GetPolicyResponse) XXX_Marshal 

func (m *GetPolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPolicyResponse) XXX_Merge 

func (dst *GetPolicyResponse) XXX_Merge(src proto.Message)

func (*GetPolicyResponse) XXX_Size 

func (m *GetPolicyResponse) XXX_Size() int

func (*GetPolicyResponse) XXX_Unmarshal 

func (m *GetPolicyResponse) XXX_Unmarshal(b []byte) error

type Job 

type Job struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type                 string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	PlanName             string   `protobuf:"bytes,3,opt,name=planName,proto3" json:"planName,omitempty"`
	PlanId               string   `protobuf:"bytes,4,opt,name=planId,proto3" json:"planId,omitempty"`
	Description          string   `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	SourceLocation       string   `protobuf:"bytes,6,opt,name=sourceLocation,proto3" json:"sourceLocation,omitempty"`
	DestLocation         string   `protobuf:"bytes,7,opt,name=destLocation,proto3" json:"destLocation,omitempty"`
	Status               string   `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"`
	CreateTime           int64    `protobuf:"varint,9,opt,name=createTime,proto3" json:"createTime,omitempty"`
	StartTime            int64    `protobuf:"varint,10,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime              int64    `protobuf:"varint,11,opt,name=endTime,proto3" json:"endTime,omitempty"`
	RemainSource         bool     `protobuf:"varint,12,opt,name=remainSource,proto3" json:"remainSource,omitempty"`
	TotalCapacity        int64    `protobuf:"varint,13,opt,name=totalCapacity,proto3" json:"totalCapacity,omitempty"`
	PassedCapacity       int64    `protobuf:"varint,14,opt,name=passedCapacity,proto3" json:"passedCapacity,omitempty"`
	TotalCount           int64    `protobuf:"varint,15,opt,name=totalCount,proto3" json:"totalCount,omitempty"`
	PassedCount          int64    `protobuf:"varint,16,opt,name=passedCount,proto3" json:"passedCount,omitempty"`
	Progress             int64    `protobuf:"varint,17,opt,name=progress,proto3" json:"progress,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Job) Descriptor 

func (*Job) Descriptor() ([]byte, []int)

func (*Job) GetCreateTime 

func (m *Job) GetCreateTime() int64

func (*Job) GetDescription 

func (m *Job) GetDescription() string

func (*Job) GetDestLocation 

func (m *Job) GetDestLocation() string

func (*Job) GetEndTime 

func (m *Job) GetEndTime() int64

func (*Job) GetId 

func (m *Job) GetId() string

func (*Job) GetPassedCapacity 

func (m *Job) GetPassedCapacity() int64

func (*Job) GetPassedCount 

func (m *Job) GetPassedCount() int64

func (*Job) GetPlanId 

func (m *Job) GetPlanId() string

func (*Job) GetPlanName 

func (m *Job) GetPlanName() string

func (*Job) GetProgress 

func (m *Job) GetProgress() int64

func (*Job) GetRemainSource 

func (m *Job) GetRemainSource() bool

func (*Job) GetSourceLocation 

func (m *Job) GetSourceLocation() string

func (*Job) GetStartTime 

func (m *Job) GetStartTime() int64

func (*Job) GetStatus 

func (m *Job) GetStatus() string

func (*Job) GetTotalCapacity 

func (m *Job) GetTotalCapacity() int64

func (*Job) GetTotalCount 

func (m *Job) GetTotalCount() int64

func (*Job) GetType 

func (m *Job) GetType() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) String 

func (m *Job) String() string

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Job) XXX_Merge 

func (dst *Job) XXX_Merge(src proto.Message)

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

func (m *Job) XXX_Unmarshal(b []byte) error

type KV 

type KV struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KV) Descriptor 

func (*KV) Descriptor() ([]byte, []int)

func (*KV) GetKey 

func (m *KV) GetKey() string

func (*KV) GetValue 

func (m *KV) GetValue() string

func (*KV) ProtoMessage 

func (*KV) ProtoMessage()

func (*KV) Reset 

func (m *KV) Reset()

func (*KV) String 

func (m *KV) String() string

func (*KV) XXX_DiscardUnknown 

func (m *KV) XXX_DiscardUnknown()

func (*KV) XXX_Marshal 

func (m *KV) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KV) XXX_Merge 

func (dst *KV) XXX_Merge(src proto.Message)

func (*KV) XXX_Size 

func (m *KV) XXX_Size() int

func (*KV) XXX_Unmarshal 

func (m *KV) XXX_Unmarshal(b []byte) error

type ListJobRequest 

type ListJobRequest struct {
	Context              string            `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Limit                int32             `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset               int32             `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	SortKeys             []string          `protobuf:"bytes,4,rep,name=sortKeys,proto3" json:"sortKeys,omitempty"`
	SortDirs             []string          `protobuf:"bytes,5,rep,name=sortDirs,proto3" json:"sortDirs,omitempty"`
	Filter               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListJobRequest) Descriptor 

func (*ListJobRequest) Descriptor() ([]byte, []int)

func (*ListJobRequest) GetContext 

func (m *ListJobRequest) GetContext() string

func (*ListJobRequest) GetFilter 

func (m *ListJobRequest) GetFilter() map[string]string

func (*ListJobRequest) GetLimit 

func (m *ListJobRequest) GetLimit() int32

func (*ListJobRequest) GetOffset 

func (m *ListJobRequest) GetOffset() int32

func (*ListJobRequest) GetSortDirs 

func (m *ListJobRequest) GetSortDirs() []string

func (*ListJobRequest) GetSortKeys 

func (m *ListJobRequest) GetSortKeys() []string

func (*ListJobRequest) ProtoMessage 

func (*ListJobRequest) ProtoMessage()

func (*ListJobRequest) Reset 

func (m *ListJobRequest) Reset()

func (*ListJobRequest) String 

func (m *ListJobRequest) String() string

func (*ListJobRequest) XXX_DiscardUnknown 

func (m *ListJobRequest) XXX_DiscardUnknown()

func (*ListJobRequest) XXX_Marshal 

func (m *ListJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListJobRequest) XXX_Merge 

func (dst *ListJobRequest) XXX_Merge(src proto.Message)

func (*ListJobRequest) XXX_Size 

func (m *ListJobRequest) XXX_Size() int

func (*ListJobRequest) XXX_Unmarshal 

func (m *ListJobRequest) XXX_Unmarshal(b []byte) error

type ListJobResponse 

type ListJobResponse struct {
	Jobs                 []*Job   `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	Next                 int32    `protobuf:"varint,2,opt,name=next,proto3" json:"next,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListJobResponse) Descriptor 

func (*ListJobResponse) Descriptor() ([]byte, []int)

func (*ListJobResponse) GetJobs 

func (m *ListJobResponse) GetJobs() []*Job

func (*ListJobResponse) GetNext 

func (m *ListJobResponse) GetNext() int32

func (*ListJobResponse) ProtoMessage 

func (*ListJobResponse) ProtoMessage()

func (*ListJobResponse) Reset 

func (m *ListJobResponse) Reset()

func (*ListJobResponse) String 

func (m *ListJobResponse) String() string

func (*ListJobResponse) XXX_DiscardUnknown 

func (m *ListJobResponse) XXX_DiscardUnknown()

func (*ListJobResponse) XXX_Marshal 

func (m *ListJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListJobResponse) XXX_Merge 

func (dst *ListJobResponse) XXX_Merge(src proto.Message)

func (*ListJobResponse) XXX_Size 

func (m *ListJobResponse) XXX_Size() int

func (*ListJobResponse) XXX_Unmarshal 

func (m *ListJobResponse) XXX_Unmarshal(b []byte) error

type ListPlanRequest 

type ListPlanRequest struct {
	Context              string            `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Limit                int32             `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset               int32             `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	SortKeys             []string          `protobuf:"bytes,4,rep,name=sortKeys,proto3" json:"sortKeys,omitempty"`
	SortDirs             []string          `protobuf:"bytes,5,rep,name=sortDirs,proto3" json:"sortDirs,omitempty"`
	Filter               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListPlanRequest) Descriptor 

func (*ListPlanRequest) Descriptor() ([]byte, []int)

func (*ListPlanRequest) GetContext 

func (m *ListPlanRequest) GetContext() string

func (*ListPlanRequest) GetFilter 

func (m *ListPlanRequest) GetFilter() map[string]string

func (*ListPlanRequest) GetLimit 

func (m *ListPlanRequest) GetLimit() int32

func (*ListPlanRequest) GetOffset 

func (m *ListPlanRequest) GetOffset() int32

func (*ListPlanRequest) GetSortDirs 

func (m *ListPlanRequest) GetSortDirs() []string

func (*ListPlanRequest) GetSortKeys 

func (m *ListPlanRequest) GetSortKeys() []string

func (*ListPlanRequest) ProtoMessage 

func (*ListPlanRequest) ProtoMessage()

func (*ListPlanRequest) Reset 

func (m *ListPlanRequest) Reset()

func (*ListPlanRequest) String 

func (m *ListPlanRequest) String() string

func (*ListPlanRequest) XXX_DiscardUnknown 

func (m *ListPlanRequest) XXX_DiscardUnknown()

func (*ListPlanRequest) XXX_Marshal 

func (m *ListPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListPlanRequest) XXX_Merge 

func (dst *ListPlanRequest) XXX_Merge(src proto.Message)

func (*ListPlanRequest) XXX_Size 

func (m *ListPlanRequest) XXX_Size() int

func (*ListPlanRequest) XXX_Unmarshal 

func (m *ListPlanRequest) XXX_Unmarshal(b []byte) error

type ListPlanResponse 

type ListPlanResponse struct {
	Plans                []*Plan  `protobuf:"bytes,1,rep,name=plans,proto3" json:"plans,omitempty"`
	Next                 int32    `protobuf:"varint,2,opt,name=next,proto3" json:"next,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListPlanResponse) Descriptor 

func (*ListPlanResponse) Descriptor() ([]byte, []int)

func (*ListPlanResponse) GetNext 

func (m *ListPlanResponse) GetNext() int32

func (*ListPlanResponse) GetPlans 

func (m *ListPlanResponse) GetPlans() []*Plan

func (*ListPlanResponse) ProtoMessage 

func (*ListPlanResponse) ProtoMessage()

func (*ListPlanResponse) Reset 

func (m *ListPlanResponse) Reset()

func (*ListPlanResponse) String 

func (m *ListPlanResponse) String() string

func (*ListPlanResponse) XXX_DiscardUnknown 

func (m *ListPlanResponse) XXX_DiscardUnknown()

func (*ListPlanResponse) XXX_Marshal 

func (m *ListPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListPlanResponse) XXX_Merge 

func (dst *ListPlanResponse) XXX_Merge(src proto.Message)

func (*ListPlanResponse) XXX_Size 

func (m *ListPlanResponse) XXX_Size() int

func (*ListPlanResponse) XXX_Unmarshal 

func (m *ListPlanResponse) XXX_Unmarshal(b []byte) error

type ListPolicyRequest 

type ListPolicyRequest struct {
	Context              string   `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListPolicyRequest) Descriptor 

func (*ListPolicyRequest) Descriptor() ([]byte, []int)

func (*ListPolicyRequest) GetContext 

func (m *ListPolicyRequest) GetContext() string

func (*ListPolicyRequest) ProtoMessage 

func (*ListPolicyRequest) ProtoMessage()

func (*ListPolicyRequest) Reset 

func (m *ListPolicyRequest) Reset()

func (*ListPolicyRequest) String 

func (m *ListPolicyRequest) String() string

func (*ListPolicyRequest) XXX_DiscardUnknown 

func (m *ListPolicyRequest) XXX_DiscardUnknown()

func (*ListPolicyRequest) XXX_Marshal 

func (m *ListPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListPolicyRequest) XXX_Merge 

func (dst *ListPolicyRequest) XXX_Merge(src proto.Message)

func (*ListPolicyRequest) XXX_Size 

func (m *ListPolicyRequest) XXX_Size() int

func (*ListPolicyRequest) XXX_Unmarshal 

func (m *ListPolicyRequest) XXX_Unmarshal(b []byte) error

type ListPolicyResponse 

type ListPolicyResponse struct {
	Err                  string    `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Policies             []*Policy `protobuf:"bytes,2,rep,name=policies,proto3" json:"policies,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListPolicyResponse) Descriptor 

func (*ListPolicyResponse) Descriptor() ([]byte, []int)

func (*ListPolicyResponse) GetErr 

func (m *ListPolicyResponse) GetErr() string

func (*ListPolicyResponse) GetPolicies 

func (m *ListPolicyResponse) GetPolicies() []*Policy

func (*ListPolicyResponse) ProtoMessage 

func (*ListPolicyResponse) ProtoMessage()

func (*ListPolicyResponse) Reset 

func (m *ListPolicyResponse) Reset()

func (*ListPolicyResponse) String 

func (m *ListPolicyResponse) String() string

func (*ListPolicyResponse) XXX_DiscardUnknown 

func (m *ListPolicyResponse) XXX_DiscardUnknown()

func (*ListPolicyResponse) XXX_Marshal 

func (m *ListPolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListPolicyResponse) XXX_Merge 

func (dst *ListPolicyResponse) XXX_Merge(src proto.Message)

func (*ListPolicyResponse) XXX_Size 

func (m *ListPolicyResponse) XXX_Size() int

func (*ListPolicyResponse) XXX_Unmarshal 

func (m *ListPolicyResponse) XXX_Unmarshal(b []byte) error

type Plan 

type Plan struct {
	Id                   string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string     `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description          string     `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Type                 string     `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	PolicyId             string     `protobuf:"bytes,5,opt,name=policyId,proto3" json:"policyId,omitempty"`
	PolicyName           string     `protobuf:"bytes,6,opt,name=policyName,proto3" json:"policyName,omitempty"`
	SourceConn           *Connector `protobuf:"bytes,7,opt,name=sourceConn,proto3" json:"sourceConn,omitempty"`
	DestConn             *Connector `protobuf:"bytes,8,opt,name=destConn,proto3" json:"destConn,omitempty"`
	Filter               *Filter    `protobuf:"bytes,9,opt,name=filter,proto3" json:"filter,omitempty"`
	RemainSource         bool       `protobuf:"varint,10,opt,name=remainSource,proto3" json:"remainSource,omitempty"`
	TenantId             string     `protobuf:"bytes,11,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	UserId               string     `protobuf:"bytes,12,opt,name=userId,proto3" json:"userId,omitempty"`
	PolicyEnabled        bool       `protobuf:"varint,13,opt,name=policyEnabled,proto3" json:"policyEnabled,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Plan) Descriptor 

func (*Plan) Descriptor() ([]byte, []int)

func (*Plan) GetDescription 

func (m *Plan) GetDescription() string

func (*Plan) GetDestConn 

func (m *Plan) GetDestConn() *Connector

func (*Plan) GetFilter 

func (m *Plan) GetFilter() *Filter

func (*Plan) GetId 

func (m *Plan) GetId() string

func (*Plan) GetName 

func (m *Plan) GetName() string

func (*Plan) GetPolicyEnabled 

func (m *Plan) GetPolicyEnabled() bool

func (*Plan) GetPolicyId 

func (m *Plan) GetPolicyId() string

func (*Plan) GetPolicyName 

func (m *Plan) GetPolicyName() string

func (*Plan) GetRemainSource 

func (m *Plan) GetRemainSource() bool

func (*Plan) GetSourceConn 

func (m *Plan) GetSourceConn() *Connector

func (*Plan) GetTenantId 

func (m *Plan) GetTenantId() string

func (*Plan) GetType 

func (m *Plan) GetType() string

func (*Plan) GetUserId 

func (m *Plan) GetUserId() string

func (*Plan) ProtoMessage 

func (*Plan) ProtoMessage()

func (*Plan) Reset 

func (m *Plan) Reset()

func (*Plan) String 

func (m *Plan) String() string

func (*Plan) XXX_DiscardUnknown 

func (m *Plan) XXX_DiscardUnknown()

func (*Plan) XXX_Marshal 

func (m *Plan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Plan) XXX_Merge 

func (dst *Plan) XXX_Merge(src proto.Message)

func (*Plan) XXX_Size 

func (m *Plan) XXX_Size() int

func (*Plan) XXX_Unmarshal 

func (m *Plan) XXX_Unmarshal(b []byte) error

type Policy 

type Policy struct {
	Id                   string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Tenant               string    `protobuf:"bytes,3,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Description          string    `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Schedule             *Schedule `protobuf:"bytes,5,opt,name=schedule,proto3" json:"schedule,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Policy) Descriptor 

func (*Policy) Descriptor() ([]byte, []int)

func (*Policy) GetDescription 

func (m *Policy) GetDescription() string

func (*Policy) GetId 

func (m *Policy) GetId() string

func (*Policy) GetName 

func (m *Policy) GetName() string

func (*Policy) GetSchedule 

func (m *Policy) GetSchedule() *Schedule

func (*Policy) GetTenant 

func (m *Policy) GetTenant() string

func (*Policy) ProtoMessage 

func (*Policy) ProtoMessage()

func (*Policy) Reset 

func (m *Policy) Reset()

func (*Policy) String 

func (m *Policy) String() string

func (*Policy) XXX_DiscardUnknown 

func (m *Policy) XXX_DiscardUnknown()

func (*Policy) XXX_Marshal 

func (m *Policy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Policy) XXX_Merge 

func (dst *Policy) XXX_Merge(src proto.Message)

func (*Policy) XXX_Size 

func (m *Policy) XXX_Size() int

func (*Policy) XXX_Unmarshal 

func (m *Policy) XXX_Unmarshal(b []byte) error

type RunPlanRequest 

type RunPlanRequest struct {
	Context              string   `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RunPlanRequest) Descriptor 

func (*RunPlanRequest) Descriptor() ([]byte, []int)

func (*RunPlanRequest) GetContext 

func (m *RunPlanRequest) GetContext() string

func (*RunPlanRequest) GetId 

func (m *RunPlanRequest) GetId() string

func (*RunPlanRequest) ProtoMessage 

func (*RunPlanRequest) ProtoMessage()

func (*RunPlanRequest) Reset 

func (m *RunPlanRequest) Reset()

func (*RunPlanRequest) String 

func (m *RunPlanRequest) String() string

func (*RunPlanRequest) XXX_DiscardUnknown 

func (m *RunPlanRequest) XXX_DiscardUnknown()

func (*RunPlanRequest) XXX_Marshal 

func (m *RunPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunPlanRequest) XXX_Merge 

func (dst *RunPlanRequest) XXX_Merge(src proto.Message)

func (*RunPlanRequest) XXX_Size 

func (m *RunPlanRequest) XXX_Size() int

func (*RunPlanRequest) XXX_Unmarshal 

func (m *RunPlanRequest) XXX_Unmarshal(b []byte) error

type RunPlanResponse 

type RunPlanResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	JobId                string   `protobuf:"bytes,2,opt,name=jobId,proto3" json:"jobId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RunPlanResponse) Descriptor 

func (*RunPlanResponse) Descriptor() ([]byte, []int)

func (*RunPlanResponse) GetErr 

func (m *RunPlanResponse) GetErr() string

func (*RunPlanResponse) GetJobId 

func (m *RunPlanResponse) GetJobId() string

func (*RunPlanResponse) ProtoMessage 

func (*RunPlanResponse) ProtoMessage()

func (*RunPlanResponse) Reset 

func (m *RunPlanResponse) Reset()

func (*RunPlanResponse) String 

func (m *RunPlanResponse) String() string

func (*RunPlanResponse) XXX_DiscardUnknown 

func (m *RunPlanResponse) XXX_DiscardUnknown()

func (*RunPlanResponse) XXX_Marshal 

func (m *RunPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunPlanResponse) XXX_Merge 

func (dst *RunPlanResponse) XXX_Merge(src proto.Message)

func (*RunPlanResponse) XXX_Size 

func (m *RunPlanResponse) XXX_Size() int

func (*RunPlanResponse) XXX_Unmarshal 

func (m *RunPlanResponse) XXX_Unmarshal(b []byte) error

type Schedule 

type Schedule struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	TiggerProperties     string   `protobuf:"bytes,2,opt,name=tiggerProperties,proto3" json:"tiggerProperties,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Schedule) Descriptor 

func (*Schedule) Descriptor() ([]byte, []int)

func (*Schedule) GetTiggerProperties 

func (m *Schedule) GetTiggerProperties() string

func (*Schedule) GetType 

func (m *Schedule) GetType() string

func (*Schedule) ProtoMessage 

func (*Schedule) ProtoMessage()

func (*Schedule) Reset 

func (m *Schedule) Reset()

func (*Schedule) String 

func (m *Schedule) String() string

func (*Schedule) XXX_DiscardUnknown 

func (m *Schedule) XXX_DiscardUnknown()

func (*Schedule) XXX_Marshal 

func (m *Schedule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Schedule) XXX_Merge 

func (dst *Schedule) XXX_Merge(src proto.Message)

func (*Schedule) XXX_Size 

func (m *Schedule) XXX_Size() int

func (*Schedule) XXX_Unmarshal 

func (m *Schedule) XXX_Unmarshal(b []byte) error

type UpdatePlanRequest 

type UpdatePlanRequest struct {
	Context              string   `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	PlanId               string   `protobuf:"bytes,2,opt,name=planId,proto3" json:"planId,omitempty"`
	Body                 string   `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdatePlanRequest) Descriptor 

func (*UpdatePlanRequest) Descriptor() ([]byte, []int)

func (*UpdatePlanRequest) GetBody 

func (m *UpdatePlanRequest) GetBody() string

func (*UpdatePlanRequest) GetContext 

func (m *UpdatePlanRequest) GetContext() string

func (*UpdatePlanRequest) GetPlanId 

func (m *UpdatePlanRequest) GetPlanId() string

func (*UpdatePlanRequest) ProtoMessage 

func (*UpdatePlanRequest) ProtoMessage()

func (*UpdatePlanRequest) Reset 

func (m *UpdatePlanRequest) Reset()

func (*UpdatePlanRequest) String 

func (m *UpdatePlanRequest) String() string

func (*UpdatePlanRequest) XXX_DiscardUnknown 

func (m *UpdatePlanRequest) XXX_DiscardUnknown()

func (*UpdatePlanRequest) XXX_Marshal 

func (m *UpdatePlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdatePlanRequest) XXX_Merge 

func (dst *UpdatePlanRequest) XXX_Merge(src proto.Message)

func (*UpdatePlanRequest) XXX_Size 

func (m *UpdatePlanRequest) XXX_Size() int

func (*UpdatePlanRequest) XXX_Unmarshal 

func (m *UpdatePlanRequest) XXX_Unmarshal(b []byte) error

type UpdatePlanResponse 

type UpdatePlanResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Plan                 *Plan    `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdatePlanResponse) Descriptor 

func (*UpdatePlanResponse) Descriptor() ([]byte, []int)

func (*UpdatePlanResponse) GetErr 

func (m *UpdatePlanResponse) GetErr() string

func (*UpdatePlanResponse) GetPlan 

func (m *UpdatePlanResponse) GetPlan() *Plan

func (*UpdatePlanResponse) ProtoMessage 

func (*UpdatePlanResponse) ProtoMessage()

func (*UpdatePlanResponse) Reset 

func (m *UpdatePlanResponse) Reset()

func (*UpdatePlanResponse) String 

func (m *UpdatePlanResponse) String() string

func (*UpdatePlanResponse) XXX_DiscardUnknown 

func (m *UpdatePlanResponse) XXX_DiscardUnknown()

func (*UpdatePlanResponse) XXX_Marshal 

func (m *UpdatePlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdatePlanResponse) XXX_Merge 

func (dst *UpdatePlanResponse) XXX_Merge(src proto.Message)

func (*UpdatePlanResponse) XXX_Size 

func (m *UpdatePlanResponse) XXX_Size() int

func (*UpdatePlanResponse) XXX_Unmarshal 

func (m *UpdatePlanResponse) XXX_Unmarshal(b []byte) error

type UpdatePolicyRequest 

type UpdatePolicyRequest struct {
	Context              string   `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	PolicyId             string   `protobuf:"bytes,2,opt,name=policyId,proto3" json:"policyId,omitempty"`
	Body                 string   `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdatePolicyRequest) Descriptor 

func (*UpdatePolicyRequest) Descriptor() ([]byte, []int)

func (*UpdatePolicyRequest) GetBody 

func (m *UpdatePolicyRequest) GetBody() string

func (*UpdatePolicyRequest) GetContext 

func (m *UpdatePolicyRequest) GetContext() string

func (*UpdatePolicyRequest) GetPolicyId 

func (m *UpdatePolicyRequest) GetPolicyId() string

func (*UpdatePolicyRequest) ProtoMessage 

func (*UpdatePolicyRequest) ProtoMessage()

func (*UpdatePolicyRequest) Reset 

func (m *UpdatePolicyRequest) Reset()

func (*UpdatePolicyRequest) String 

func (m *UpdatePolicyRequest) String() string

func (*UpdatePolicyRequest) XXX_DiscardUnknown 

func (m *UpdatePolicyRequest) XXX_DiscardUnknown()

func (*UpdatePolicyRequest) XXX_Marshal 

func (m *UpdatePolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdatePolicyRequest) XXX_Merge 

func (dst *UpdatePolicyRequest) XXX_Merge(src proto.Message)

func (*UpdatePolicyRequest) XXX_Size 

func (m *UpdatePolicyRequest) XXX_Size() int

func (*UpdatePolicyRequest) XXX_Unmarshal 

func (m *UpdatePolicyRequest) XXX_Unmarshal(b []byte) error

type UpdatePolicyResponse 

type UpdatePolicyResponse struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Policy               *Policy  `protobuf:"bytes,2,opt,name=policy,proto3" json:"policy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdatePolicyResponse) Descriptor 

func (*UpdatePolicyResponse) Descriptor() ([]byte, []int)

func (*UpdatePolicyResponse) GetErr 

func (m *UpdatePolicyResponse) GetErr() string

func (*UpdatePolicyResponse) GetPolicy 

func (m *UpdatePolicyResponse) GetPolicy() *Policy

func (*UpdatePolicyResponse) ProtoMessage 

func (*UpdatePolicyResponse) ProtoMessage()

func (*UpdatePolicyResponse) Reset 

func (m *UpdatePolicyResponse) Reset()

func (*UpdatePolicyResponse) String 

func (m *UpdatePolicyResponse) String() string

func (*UpdatePolicyResponse) XXX_DiscardUnknown 

func (m *UpdatePolicyResponse) XXX_DiscardUnknown()

func (*UpdatePolicyResponse) XXX_Marshal 

func (m *UpdatePolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdatePolicyResponse) XXX_Merge 

func (dst *UpdatePolicyResponse) XXX_Merge(src proto.Message)

func (*UpdatePolicyResponse) XXX_Size 

func (m *UpdatePolicyResponse) XXX_Size() int

func (*UpdatePolicyResponse) XXX_Unmarshal 

func (m *UpdatePolicyResponse) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.