dataflow

package
v0.5.3 Latest Latest
Warning

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

Go to latest
Published: Jun 3, 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 DataFlowService

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL