dataflow.pb.go

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

package dataflow

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

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

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

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 (m *Schedule) Reset()         { *m = Schedule{} }
func (m *Schedule) String() string { return proto.CompactTextString(m) }
func (*Schedule) ProtoMessage()    {}
func (*Schedule) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{0}
}
func (m *Schedule) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Schedule.Unmarshal(m, b)
}
func (m *Schedule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Schedule.Marshal(b, m, deterministic)
}
func (dst *Schedule) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Schedule.Merge(dst, src)
}
func (m *Schedule) XXX_Size() int {
	return xxx_messageInfo_Schedule.Size(m)
}
func (m *Schedule) XXX_DiscardUnknown() {
	xxx_messageInfo_Schedule.DiscardUnknown(m)
}

var xxx_messageInfo_Schedule proto.InternalMessageInfo

func (m *Schedule) GetType() string {
	if m != nil {
		return m.Type
	}
	return ""
}

func (m *Schedule) GetTiggerProperties() string {
	if m != nil {
		return m.TiggerProperties
	}
	return ""
}

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

func (m *Policy) Reset()         { *m = Policy{} }
func (m *Policy) String() string { return proto.CompactTextString(m) }
func (*Policy) ProtoMessage()    {}
func (*Policy) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{1}
}
func (m *Policy) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Policy.Unmarshal(m, b)
}
func (m *Policy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Policy.Marshal(b, m, deterministic)
}
func (dst *Policy) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Policy.Merge(dst, src)
}
func (m *Policy) XXX_Size() int {
	return xxx_messageInfo_Policy.Size(m)
}
func (m *Policy) XXX_DiscardUnknown() {
	xxx_messageInfo_Policy.DiscardUnknown(m)
}

var xxx_messageInfo_Policy proto.InternalMessageInfo

func (m *Policy) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *Policy) GetTenantId() string {
	if m != nil {
		return m.TenantId
	}
	return ""
}

func (m *Policy) GetUserId() string {
	if m != nil {
		return m.UserId
	}
	return ""
}

func (m *Policy) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *Policy) GetTenant() string {
	if m != nil {
		return m.Tenant
	}
	return ""
}

func (m *Policy) GetDescription() string {
	if m != nil {
		return m.Description
	}
	return ""
}

func (m *Policy) GetSchedule() *Schedule {
	if m != nil {
		return m.Schedule
	}
	return nil
}

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

func (m *GetPolicyRequest) Reset()         { *m = GetPolicyRequest{} }
func (m *GetPolicyRequest) String() string { return proto.CompactTextString(m) }
func (*GetPolicyRequest) ProtoMessage()    {}
func (*GetPolicyRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{2}
}
func (m *GetPolicyRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetPolicyRequest.Unmarshal(m, b)
}
func (m *GetPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetPolicyRequest.Marshal(b, m, deterministic)
}
func (dst *GetPolicyRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetPolicyRequest.Merge(dst, src)
}
func (m *GetPolicyRequest) XXX_Size() int {
	return xxx_messageInfo_GetPolicyRequest.Size(m)
}
func (m *GetPolicyRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_GetPolicyRequest.DiscardUnknown(m)
}

var xxx_messageInfo_GetPolicyRequest proto.InternalMessageInfo

func (m *GetPolicyRequest) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

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 (m *GetPolicyResponse) Reset()         { *m = GetPolicyResponse{} }
func (m *GetPolicyResponse) String() string { return proto.CompactTextString(m) }
func (*GetPolicyResponse) ProtoMessage()    {}
func (*GetPolicyResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{3}
}
func (m *GetPolicyResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetPolicyResponse.Unmarshal(m, b)
}
func (m *GetPolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetPolicyResponse.Marshal(b, m, deterministic)
}
func (dst *GetPolicyResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetPolicyResponse.Merge(dst, src)
}
func (m *GetPolicyResponse) XXX_Size() int {
	return xxx_messageInfo_GetPolicyResponse.Size(m)
}
func (m *GetPolicyResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_GetPolicyResponse.DiscardUnknown(m)
}

var xxx_messageInfo_GetPolicyResponse proto.InternalMessageInfo

func (m *GetPolicyResponse) GetErr() string {
	if m != nil {
		return m.Err
	}
	return ""
}

func (m *GetPolicyResponse) GetPolicy() *Policy {
	if m != nil {
		return m.Policy
	}
	return nil
}

type ListPolicyRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListPolicyRequest) Reset()         { *m = ListPolicyRequest{} }
func (m *ListPolicyRequest) String() string { return proto.CompactTextString(m) }
func (*ListPolicyRequest) ProtoMessage()    {}
func (*ListPolicyRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{4}
}
func (m *ListPolicyRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListPolicyRequest.Unmarshal(m, b)
}
func (m *ListPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListPolicyRequest.Marshal(b, m, deterministic)
}
func (dst *ListPolicyRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListPolicyRequest.Merge(dst, src)
}
func (m *ListPolicyRequest) XXX_Size() int {
	return xxx_messageInfo_ListPolicyRequest.Size(m)
}
func (m *ListPolicyRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListPolicyRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListPolicyRequest proto.InternalMessageInfo

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 (m *ListPolicyResponse) Reset()         { *m = ListPolicyResponse{} }
func (m *ListPolicyResponse) String() string { return proto.CompactTextString(m) }
func (*ListPolicyResponse) ProtoMessage()    {}
func (*ListPolicyResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{5}
}
func (m *ListPolicyResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListPolicyResponse.Unmarshal(m, b)
}
func (m *ListPolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListPolicyResponse.Marshal(b, m, deterministic)
}
func (dst *ListPolicyResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListPolicyResponse.Merge(dst, src)
}
func (m *ListPolicyResponse) XXX_Size() int {
	return xxx_messageInfo_ListPolicyResponse.Size(m)
}
func (m *ListPolicyResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListPolicyResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListPolicyResponse proto.InternalMessageInfo

func (m *ListPolicyResponse) GetErr() string {
	if m != nil {
		return m.Err
	}
	return ""
}

func (m *ListPolicyResponse) GetPolicies() []*Policy {
	if m != nil {
		return m.Policies
	}
	return nil
}

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

func (m *CreatePolicyRequest) Reset()         { *m = CreatePolicyRequest{} }
func (m *CreatePolicyRequest) String() string { return proto.CompactTextString(m) }
func (*CreatePolicyRequest) ProtoMessage()    {}
func (*CreatePolicyRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{6}
}
func (m *CreatePolicyRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreatePolicyRequest.Unmarshal(m, b)
}
func (m *CreatePolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreatePolicyRequest.Marshal(b, m, deterministic)
}
func (dst *CreatePolicyRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreatePolicyRequest.Merge(dst, src)
}
func (m *CreatePolicyRequest) XXX_Size() int {
	return xxx_messageInfo_CreatePolicyRequest.Size(m)
}
func (m *CreatePolicyRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreatePolicyRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreatePolicyRequest proto.InternalMessageInfo

func (m *CreatePolicyRequest) GetPolicy() *Policy {
	if m != nil {
		return m.Policy
	}
	return nil
}

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 (m *CreatePolicyResponse) Reset()         { *m = CreatePolicyResponse{} }
func (m *CreatePolicyResponse) String() string { return proto.CompactTextString(m) }
func (*CreatePolicyResponse) ProtoMessage()    {}
func (*CreatePolicyResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{7}
}
func (m *CreatePolicyResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreatePolicyResponse.Unmarshal(m, b)
}
func (m *CreatePolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreatePolicyResponse.Marshal(b, m, deterministic)
}
func (dst *CreatePolicyResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreatePolicyResponse.Merge(dst, src)
}
func (m *CreatePolicyResponse) XXX_Size() int {
	return xxx_messageInfo_CreatePolicyResponse.Size(m)
}
func (m *CreatePolicyResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_CreatePolicyResponse.DiscardUnknown(m)
}

var xxx_messageInfo_CreatePolicyResponse proto.InternalMessageInfo

func (m *CreatePolicyResponse) GetErr() string {
	if m != nil {
		return m.Err
	}
	return ""
}

func (m *CreatePolicyResponse) GetPolicy() *Policy {
	if m != nil {
		return m.Policy
	}
	return nil
}

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

func (m *UpdatePolicyRequest) Reset()         { *m = UpdatePolicyRequest{} }
func (m *UpdatePolicyRequest) String() string { return proto.CompactTextString(m) }
func (*UpdatePolicyRequest) ProtoMessage()    {}
func (*UpdatePolicyRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{8}
}
func (m *UpdatePolicyRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_UpdatePolicyRequest.Unmarshal(m, b)
}
func (m *UpdatePolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_UpdatePolicyRequest.Marshal(b, m, deterministic)
}
func (dst *UpdatePolicyRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_UpdatePolicyRequest.Merge(dst, src)
}
func (m *UpdatePolicyRequest) XXX_Size() int {
	return xxx_messageInfo_UpdatePolicyRequest.Size(m)
}
func (m *UpdatePolicyRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_UpdatePolicyRequest.DiscardUnknown(m)
}

var xxx_messageInfo_UpdatePolicyRequest proto.InternalMessageInfo

func (m *UpdatePolicyRequest) GetPolicyId() string {
	if m != nil {
		return m.PolicyId
	}
	return ""
}

func (m *UpdatePolicyRequest) GetBody() string {
	if m != nil {
		return m.Body
	}
	return ""
}

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 (m *UpdatePolicyResponse) Reset()         { *m = UpdatePolicyResponse{} }
func (m *UpdatePolicyResponse) String() string { return proto.CompactTextString(m) }
func (*UpdatePolicyResponse) ProtoMessage()    {}
func (*UpdatePolicyResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{9}
}
func (m *UpdatePolicyResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_UpdatePolicyResponse.Unmarshal(m, b)
}
func (m *UpdatePolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_UpdatePolicyResponse.Marshal(b, m, deterministic)
}
func (dst *UpdatePolicyResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_UpdatePolicyResponse.Merge(dst, src)
}
func (m *UpdatePolicyResponse) XXX_Size() int {
	return xxx_messageInfo_UpdatePolicyResponse.Size(m)
}
func (m *UpdatePolicyResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_UpdatePolicyResponse.DiscardUnknown(m)
}

var xxx_messageInfo_UpdatePolicyResponse proto.InternalMessageInfo

func (m *UpdatePolicyResponse) GetErr() string {
	if m != nil {
		return m.Err
	}
	return ""
}

func (m *UpdatePolicyResponse) GetPolicy() *Policy {
	if m != nil {
		return m.Policy
	}
	return nil
}

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

func (m *DeletePolicyRequest) Reset()         { *m = DeletePolicyRequest{} }
func (m *DeletePolicyRequest) String() string { return proto.CompactTextString(m) }
func (*DeletePolicyRequest) ProtoMessage()    {}
func (*DeletePolicyRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{10}
}
func (m *DeletePolicyRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DeletePolicyRequest.Unmarshal(m, b)
}
func (m *DeletePolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DeletePolicyRequest.Marshal(b, m, deterministic)
}
func (dst *DeletePolicyRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DeletePolicyRequest.Merge(dst, src)
}
func (m *DeletePolicyRequest) XXX_Size() int {
	return xxx_messageInfo_DeletePolicyRequest.Size(m)
}
func (m *DeletePolicyRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_DeletePolicyRequest.DiscardUnknown(m)
}

var xxx_messageInfo_DeletePolicyRequest proto.InternalMessageInfo

func (m *DeletePolicyRequest) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

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 (m *DeletePolicyResponse) Reset()         { *m = DeletePolicyResponse{} }
func (m *DeletePolicyResponse) String() string { return proto.CompactTextString(m) }
func (*DeletePolicyResponse) ProtoMessage()    {}
func (*DeletePolicyResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{11}
}
func (m *DeletePolicyResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DeletePolicyResponse.Unmarshal(m, b)
}
func (m *DeletePolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DeletePolicyResponse.Marshal(b, m, deterministic)
}
func (dst *DeletePolicyResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DeletePolicyResponse.Merge(dst, src)
}
func (m *DeletePolicyResponse) XXX_Size() int {
	return xxx_messageInfo_DeletePolicyResponse.Size(m)
}
func (m *DeletePolicyResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_DeletePolicyResponse.DiscardUnknown(m)
}

var xxx_messageInfo_DeletePolicyResponse proto.InternalMessageInfo

func (m *DeletePolicyResponse) GetErr() string {
	if m != nil {
		return m.Err
	}
	return ""
}

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 (m *KV) Reset()         { *m = KV{} }
func (m *KV) String() string { return proto.CompactTextString(m) }
func (*KV) ProtoMessage()    {}
func (*KV) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{12}
}
func (m *KV) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_KV.Unmarshal(m, b)
}
func (m *KV) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_KV.Marshal(b, m, deterministic)
}
func (dst *KV) XXX_Merge(src proto.Message) {
	xxx_messageInfo_KV.Merge(dst, src)
}
func (m *KV) XXX_Size() int {
	return xxx_messageInfo_KV.Size(m)
}
func (m *KV) XXX_DiscardUnknown() {
	xxx_messageInfo_KV.DiscardUnknown(m)
}

var xxx_messageInfo_KV proto.InternalMessageInfo

func (m *KV) GetKey() string {
	if m != nil {
		return m.Key
	}
	return ""
}

func (m *KV) GetValue() string {
	if m != nil {
		return m.Value
	}
	return ""
}

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 (m *Filter) Reset()         { *m = Filter{} }
func (m *Filter) String() string { return proto.CompactTextString(m) }
func (*Filter) ProtoMessage()    {}
func (*Filter) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{13}
}
func (m *Filter) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Filter.Unmarshal(m, b)
}
func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Filter.Marshal(b, m, deterministic)
}
func (dst *Filter) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Filter.Merge(dst, src)
}
func (m *Filter) XXX_Size() int {
	return xxx_messageInfo_Filter.Size(m)
}
func (m *Filter) XXX_DiscardUnknown() {
	xxx_messageInfo_Filter.DiscardUnknown(m)
}

var xxx_messageInfo_Filter proto.InternalMessageInfo

func (m *Filter) GetPrefix() string {
	if m != nil {
		return m.Prefix
	}
	return ""
}

func (m *Filter) GetTag() []*KV {
	if m != nil {
		return m.Tag
	}
	return nil
}

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 (m *Connector) Reset()         { *m = Connector{} }
func (m *Connector) String() string { return proto.CompactTextString(m) }
func (*Connector) ProtoMessage()    {}
func (*Connector) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{14}
}
func (m *Connector) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Connector.Unmarshal(m, b)
}
func (m *Connector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Connector.Marshal(b, m, deterministic)
}
func (dst *Connector) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Connector.Merge(dst, src)
}
func (m *Connector) XXX_Size() int {
	return xxx_messageInfo_Connector.Size(m)
}
func (m *Connector) XXX_DiscardUnknown() {
	xxx_messageInfo_Connector.DiscardUnknown(m)
}

var xxx_messageInfo_Connector proto.InternalMessageInfo

func (m *Connector) GetStorType() string {
	if m != nil {
		return m.StorType
	}
	return ""
}

func (m *Connector) GetBucketName() string {
	if m != nil {
		return m.BucketName
	}
	return ""
}

func (m *Connector) GetConnConfig() []*KV {
	if m != nil {
		return m.ConnConfig
	}
	return nil
}

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 (m *Plan) Reset()         { *m = Plan{} }
func (m *Plan) String() string { return proto.CompactTextString(m) }
func (*Plan) ProtoMessage()    {}
func (*Plan) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{15}
}
func (m *Plan) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Plan.Unmarshal(m, b)
}
func (m *Plan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Plan.Marshal(b, m, deterministic)
}
func (dst *Plan) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Plan.Merge(dst, src)
}
func (m *Plan) XXX_Size() int {
	return xxx_messageInfo_Plan.Size(m)
}
func (m *Plan) XXX_DiscardUnknown() {
	xxx_messageInfo_Plan.DiscardUnknown(m)
}

var xxx_messageInfo_Plan proto.InternalMessageInfo

func (m *Plan) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *Plan) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *Plan) GetDescription() string {
	if m != nil {
		return m.Description
	}
	return ""
}

func (m *Plan) GetType() string {
	if m != nil {
		return m.Type
	}
	return ""
}

func (m *Plan) GetPolicyId() string {
	if m != nil {
		return m.PolicyId
	}
	return ""
}

func (m *Plan) GetPolicyName() string {
	if m != nil {
		return m.PolicyName
	}
	return ""
}

func (m *Plan) GetSourceConn() *Connector {
	if m != nil {
		return m.SourceConn
	}
	return nil
}

func (m *Plan) GetDestConn() *Connector {
	if m != nil {
		return m.DestConn
	}
	return nil
}

func (m *Plan) GetFilter() *Filter {
	if m != nil {
		return m.Filter
	}
	return nil
}

func (m *Plan) GetRemainSource() bool {
	if m != nil {
		return m.RemainSource
	}
	return false
}

func (m *Plan) GetTenantId() string {
	if m != nil {
		return m.TenantId
	}
	return ""
}

func (m *Plan) GetUserId() string {
	if m != nil {
		return m.UserId
	}
	return ""
}

func (m *Plan) GetPolicyEnabled() bool {
	if m != nil {
		return m.PolicyEnabled
	}
	return false
}

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

func (m *CreatePlanRequest) Reset()         { *m = CreatePlanRequest{} }
func (m *CreatePlanRequest) String() string { return proto.CompactTextString(m) }
func (*CreatePlanRequest) ProtoMessage()    {}
func (*CreatePlanRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{16}
}
func (m *CreatePlanRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreatePlanRequest.Unmarshal(m, b)
}
func (m *CreatePlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreatePlanRequest.Marshal(b, m, deterministic)
}
func (dst *CreatePlanRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreatePlanRequest.Merge(dst, src)
}
func (m *CreatePlanRequest) XXX_Size() int {
	return xxx_messageInfo_CreatePlanRequest.Size(m)
}
func (m *CreatePlanRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_CreatePlanRequest.DiscardUnknown(m)
}

var xxx_messageInfo_CreatePlanRequest proto.InternalMessageInfo

func (m *CreatePlanRequest) GetPlan() *Plan {
	if m != nil {
		return m.Plan
	}
	return nil
}

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 (m *CreatePlanResponse) Reset()         { *m = CreatePlanResponse{} }
func (m *CreatePlanResponse) String() string { return proto.CompactTextString(m) }
func (*CreatePlanResponse) ProtoMessage()    {}
func (*CreatePlanResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{17}
}
func (m *CreatePlanResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_CreatePlanResponse.Unmarshal(m, b)
}
func (m *CreatePlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_CreatePlanResponse.Marshal(b, m, deterministic)
}
func (dst *CreatePlanResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_CreatePlanResponse.Merge(dst, src)
}
func (m *CreatePlanResponse) XXX_Size() int {
	return xxx_messageInfo_CreatePlanResponse.Size(m)
}
func (m *CreatePlanResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_CreatePlanResponse.DiscardUnknown(m)
}

var xxx_messageInfo_CreatePlanResponse proto.InternalMessageInfo

func (m *CreatePlanResponse) GetErr() string {
	if m != nil {
		return m.Err
	}
	return ""
}

func (m *CreatePlanResponse) GetPlan() *Plan {
	if m != nil {
		return m.Plan
	}
	return nil
}

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

func (m *GetPlanRequest) Reset()         { *m = GetPlanRequest{} }
func (m *GetPlanRequest) String() string { return proto.CompactTextString(m) }
func (*GetPlanRequest) ProtoMessage()    {}
func (*GetPlanRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{18}
}
func (m *GetPlanRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetPlanRequest.Unmarshal(m, b)
}
func (m *GetPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetPlanRequest.Marshal(b, m, deterministic)
}
func (dst *GetPlanRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetPlanRequest.Merge(dst, src)
}
func (m *GetPlanRequest) XXX_Size() int {
	return xxx_messageInfo_GetPlanRequest.Size(m)
}
func (m *GetPlanRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_GetPlanRequest.DiscardUnknown(m)
}

var xxx_messageInfo_GetPlanRequest proto.InternalMessageInfo

func (m *GetPlanRequest) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

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 (m *GetPlanResponse) Reset()         { *m = GetPlanResponse{} }
func (m *GetPlanResponse) String() string { return proto.CompactTextString(m) }
func (*GetPlanResponse) ProtoMessage()    {}
func (*GetPlanResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{19}
}
func (m *GetPlanResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetPlanResponse.Unmarshal(m, b)
}
func (m *GetPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetPlanResponse.Marshal(b, m, deterministic)
}
func (dst *GetPlanResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetPlanResponse.Merge(dst, src)
}
func (m *GetPlanResponse) XXX_Size() int {
	return xxx_messageInfo_GetPlanResponse.Size(m)
}
func (m *GetPlanResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_GetPlanResponse.DiscardUnknown(m)
}

var xxx_messageInfo_GetPlanResponse proto.InternalMessageInfo

func (m *GetPlanResponse) GetErr() string {
	if m != nil {
		return m.Err
	}
	return ""
}

func (m *GetPlanResponse) GetPlan() *Plan {
	if m != nil {
		return m.Plan
	}
	return nil
}

type ListPlanRequest struct {
	Limit                int32             `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset               int32             `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	SortKeys             []string          `protobuf:"bytes,3,rep,name=sortKeys,proto3" json:"sortKeys,omitempty"`
	SortDirs             []string          `protobuf:"bytes,4,rep,name=sortDirs,proto3" json:"sortDirs,omitempty"`
	Filter               map[string]string `protobuf:"bytes,5,rep,name=Filter,proto3" json:"Filter,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *ListPlanRequest) Reset()         { *m = ListPlanRequest{} }
func (m *ListPlanRequest) String() string { return proto.CompactTextString(m) }
func (*ListPlanRequest) ProtoMessage()    {}
func (*ListPlanRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{20}
}
func (m *ListPlanRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListPlanRequest.Unmarshal(m, b)
}
func (m *ListPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListPlanRequest.Marshal(b, m, deterministic)
}
func (dst *ListPlanRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListPlanRequest.Merge(dst, src)
}
func (m *ListPlanRequest) XXX_Size() int {
	return xxx_messageInfo_ListPlanRequest.Size(m)
}
func (m *ListPlanRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListPlanRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListPlanRequest proto.InternalMessageInfo

func (m *ListPlanRequest) GetLimit() int32 {
	if m != nil {
		return m.Limit
	}
	return 0
}

func (m *ListPlanRequest) GetOffset() int32 {
	if m != nil {
		return m.Offset
	}
	return 0
}

func (m *ListPlanRequest) GetSortKeys() []string {
	if m != nil {
		return m.SortKeys
	}
	return nil
}

func (m *ListPlanRequest) GetSortDirs() []string {
	if m != nil {
		return m.SortDirs
	}
	return nil
}

func (m *ListPlanRequest) GetFilter() map[string]string {
	if m != nil {
		return m.Filter
	}
	return nil
}

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 (m *ListPlanResponse) Reset()         { *m = ListPlanResponse{} }
func (m *ListPlanResponse) String() string { return proto.CompactTextString(m) }
func (*ListPlanResponse) ProtoMessage()    {}
func (*ListPlanResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{21}
}
func (m *ListPlanResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListPlanResponse.Unmarshal(m, b)
}
func (m *ListPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListPlanResponse.Marshal(b, m, deterministic)
}
func (dst *ListPlanResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListPlanResponse.Merge(dst, src)
}
func (m *ListPlanResponse) XXX_Size() int {
	return xxx_messageInfo_ListPlanResponse.Size(m)
}
func (m *ListPlanResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListPlanResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListPlanResponse proto.InternalMessageInfo

func (m *ListPlanResponse) GetPlans() []*Plan {
	if m != nil {
		return m.Plans
	}
	return nil
}

func (m *ListPlanResponse) GetNext() int32 {
	if m != nil {
		return m.Next
	}
	return 0
}

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

func (m *UpdatePlanRequest) Reset()         { *m = UpdatePlanRequest{} }
func (m *UpdatePlanRequest) String() string { return proto.CompactTextString(m) }
func (*UpdatePlanRequest) ProtoMessage()    {}
func (*UpdatePlanRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{22}
}
func (m *UpdatePlanRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_UpdatePlanRequest.Unmarshal(m, b)
}
func (m *UpdatePlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_UpdatePlanRequest.Marshal(b, m, deterministic)
}
func (dst *UpdatePlanRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_UpdatePlanRequest.Merge(dst, src)
}
func (m *UpdatePlanRequest) XXX_Size() int {
	return xxx_messageInfo_UpdatePlanRequest.Size(m)
}
func (m *UpdatePlanRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_UpdatePlanRequest.DiscardUnknown(m)
}

var xxx_messageInfo_UpdatePlanRequest proto.InternalMessageInfo

func (m *UpdatePlanRequest) GetPlanId() string {
	if m != nil {
		return m.PlanId
	}
	return ""
}

func (m *UpdatePlanRequest) GetBody() string {
	if m != nil {
		return m.Body
	}
	return ""
}

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 (m *UpdatePlanResponse) Reset()         { *m = UpdatePlanResponse{} }
func (m *UpdatePlanResponse) String() string { return proto.CompactTextString(m) }
func (*UpdatePlanResponse) ProtoMessage()    {}
func (*UpdatePlanResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{23}
}
func (m *UpdatePlanResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_UpdatePlanResponse.Unmarshal(m, b)
}
func (m *UpdatePlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_UpdatePlanResponse.Marshal(b, m, deterministic)
}
func (dst *UpdatePlanResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_UpdatePlanResponse.Merge(dst, src)
}
func (m *UpdatePlanResponse) XXX_Size() int {
	return xxx_messageInfo_UpdatePlanResponse.Size(m)
}
func (m *UpdatePlanResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_UpdatePlanResponse.DiscardUnknown(m)
}

var xxx_messageInfo_UpdatePlanResponse proto.InternalMessageInfo

func (m *UpdatePlanResponse) GetErr() string {
	if m != nil {
		return m.Err
	}
	return ""
}

func (m *UpdatePlanResponse) GetPlan() *Plan {
	if m != nil {
		return m.Plan
	}
	return nil
}

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

func (m *DeletePlanRequest) Reset()         { *m = DeletePlanRequest{} }
func (m *DeletePlanRequest) String() string { return proto.CompactTextString(m) }
func (*DeletePlanRequest) ProtoMessage()    {}
func (*DeletePlanRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{24}
}
func (m *DeletePlanRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DeletePlanRequest.Unmarshal(m, b)
}
func (m *DeletePlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DeletePlanRequest.Marshal(b, m, deterministic)
}
func (dst *DeletePlanRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DeletePlanRequest.Merge(dst, src)
}
func (m *DeletePlanRequest) XXX_Size() int {
	return xxx_messageInfo_DeletePlanRequest.Size(m)
}
func (m *DeletePlanRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_DeletePlanRequest.DiscardUnknown(m)
}

var xxx_messageInfo_DeletePlanRequest proto.InternalMessageInfo

func (m *DeletePlanRequest) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

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 (m *DeletePlanResponse) Reset()         { *m = DeletePlanResponse{} }
func (m *DeletePlanResponse) String() string { return proto.CompactTextString(m) }
func (*DeletePlanResponse) ProtoMessage()    {}
func (*DeletePlanResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{25}
}
func (m *DeletePlanResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_DeletePlanResponse.Unmarshal(m, b)
}
func (m *DeletePlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_DeletePlanResponse.Marshal(b, m, deterministic)
}
func (dst *DeletePlanResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_DeletePlanResponse.Merge(dst, src)
}
func (m *DeletePlanResponse) XXX_Size() int {
	return xxx_messageInfo_DeletePlanResponse.Size(m)
}
func (m *DeletePlanResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_DeletePlanResponse.DiscardUnknown(m)
}

var xxx_messageInfo_DeletePlanResponse proto.InternalMessageInfo

func (m *DeletePlanResponse) GetErr() string {
	if m != nil {
		return m.Err
	}
	return ""
}

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

func (m *RunPlanRequest) Reset()         { *m = RunPlanRequest{} }
func (m *RunPlanRequest) String() string { return proto.CompactTextString(m) }
func (*RunPlanRequest) ProtoMessage()    {}
func (*RunPlanRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{26}
}
func (m *RunPlanRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_RunPlanRequest.Unmarshal(m, b)
}
func (m *RunPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_RunPlanRequest.Marshal(b, m, deterministic)
}
func (dst *RunPlanRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_RunPlanRequest.Merge(dst, src)
}
func (m *RunPlanRequest) XXX_Size() int {
	return xxx_messageInfo_RunPlanRequest.Size(m)
}
func (m *RunPlanRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_RunPlanRequest.DiscardUnknown(m)
}

var xxx_messageInfo_RunPlanRequest proto.InternalMessageInfo

func (m *RunPlanRequest) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

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 (m *RunPlanResponse) Reset()         { *m = RunPlanResponse{} }
func (m *RunPlanResponse) String() string { return proto.CompactTextString(m) }
func (*RunPlanResponse) ProtoMessage()    {}
func (*RunPlanResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{27}
}
func (m *RunPlanResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_RunPlanResponse.Unmarshal(m, b)
}
func (m *RunPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_RunPlanResponse.Marshal(b, m, deterministic)
}
func (dst *RunPlanResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_RunPlanResponse.Merge(dst, src)
}
func (m *RunPlanResponse) XXX_Size() int {
	return xxx_messageInfo_RunPlanResponse.Size(m)
}
func (m *RunPlanResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_RunPlanResponse.DiscardUnknown(m)
}

var xxx_messageInfo_RunPlanResponse proto.InternalMessageInfo

func (m *RunPlanResponse) GetErr() string {
	if m != nil {
		return m.Err
	}
	return ""
}

func (m *RunPlanResponse) GetJobId() string {
	if m != nil {
		return m.JobId
	}
	return ""
}

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

func (m *Job) Reset()         { *m = Job{} }
func (m *Job) String() string { return proto.CompactTextString(m) }
func (*Job) ProtoMessage()    {}
func (*Job) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{28}
}
func (m *Job) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Job.Unmarshal(m, b)
}
func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Job.Marshal(b, m, deterministic)
}
func (dst *Job) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Job.Merge(dst, src)
}
func (m *Job) XXX_Size() int {
	return xxx_messageInfo_Job.Size(m)
}
func (m *Job) XXX_DiscardUnknown() {
	xxx_messageInfo_Job.DiscardUnknown(m)
}

var xxx_messageInfo_Job proto.InternalMessageInfo

func (m *Job) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *Job) GetTenantId() string {
	if m != nil {
		return m.TenantId
	}
	return ""
}

func (m *Job) GetUserId() string {
	if m != nil {
		return m.UserId
	}
	return ""
}

func (m *Job) GetType() string {
	if m != nil {
		return m.Type
	}
	return ""
}

func (m *Job) GetPlanName() string {
	if m != nil {
		return m.PlanName
	}
	return ""
}

func (m *Job) GetPlanId() string {
	if m != nil {
		return m.PlanId
	}
	return ""
}

func (m *Job) GetDescription() string {
	if m != nil {
		return m.Description
	}
	return ""
}

func (m *Job) GetSourceLocation() string {
	if m != nil {
		return m.SourceLocation
	}
	return ""
}

func (m *Job) GetDestLocation() string {
	if m != nil {
		return m.DestLocation
	}
	return ""
}

func (m *Job) GetStatus() string {
	if m != nil {
		return m.Status
	}
	return ""
}

func (m *Job) GetCreateTime() int64 {
	if m != nil {
		return m.CreateTime
	}
	return 0
}

func (m *Job) GetStartTime() int64 {
	if m != nil {
		return m.StartTime
	}
	return 0
}

func (m *Job) GetEndTime() int64 {
	if m != nil {
		return m.EndTime
	}
	return 0
}

func (m *Job) GetRemainSource() bool {
	if m != nil {
		return m.RemainSource
	}
	return false
}

func (m *Job) GetTotalCapacity() int64 {
	if m != nil {
		return m.TotalCapacity
	}
	return 0
}

func (m *Job) GetPassedCapacity() int64 {
	if m != nil {
		return m.PassedCapacity
	}
	return 0
}

func (m *Job) GetTotalCount() int64 {
	if m != nil {
		return m.TotalCount
	}
	return 0
}

func (m *Job) GetPassedCount() int64 {
	if m != nil {
		return m.PassedCount
	}
	return 0
}

func (m *Job) GetProgress() int64 {
	if m != nil {
		return m.Progress
	}
	return 0
}

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

func (m *GetJobRequest) Reset()         { *m = GetJobRequest{} }
func (m *GetJobRequest) String() string { return proto.CompactTextString(m) }
func (*GetJobRequest) ProtoMessage()    {}
func (*GetJobRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{29}
}
func (m *GetJobRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetJobRequest.Unmarshal(m, b)
}
func (m *GetJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetJobRequest.Marshal(b, m, deterministic)
}
func (dst *GetJobRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetJobRequest.Merge(dst, src)
}
func (m *GetJobRequest) XXX_Size() int {
	return xxx_messageInfo_GetJobRequest.Size(m)
}
func (m *GetJobRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_GetJobRequest.DiscardUnknown(m)
}

var xxx_messageInfo_GetJobRequest proto.InternalMessageInfo

func (m *GetJobRequest) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

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 (m *GetJobResponse) Reset()         { *m = GetJobResponse{} }
func (m *GetJobResponse) String() string { return proto.CompactTextString(m) }
func (*GetJobResponse) ProtoMessage()    {}
func (*GetJobResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{30}
}
func (m *GetJobResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetJobResponse.Unmarshal(m, b)
}
func (m *GetJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetJobResponse.Marshal(b, m, deterministic)
}
func (dst *GetJobResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetJobResponse.Merge(dst, src)
}
func (m *GetJobResponse) XXX_Size() int {
	return xxx_messageInfo_GetJobResponse.Size(m)
}
func (m *GetJobResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_GetJobResponse.DiscardUnknown(m)
}

var xxx_messageInfo_GetJobResponse proto.InternalMessageInfo

func (m *GetJobResponse) GetErr() string {
	if m != nil {
		return m.Err
	}
	return ""
}

func (m *GetJobResponse) GetJob() *Job {
	if m != nil {
		return m.Job
	}
	return nil
}

type ListJobRequest struct {
	Limit                int32             `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset               int32             `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	SortKeys             []string          `protobuf:"bytes,3,rep,name=sortKeys,proto3" json:"sortKeys,omitempty"`
	SortDirs             []string          `protobuf:"bytes,4,rep,name=sortDirs,proto3" json:"sortDirs,omitempty"`
	Filter               map[string]string `protobuf:"bytes,5,rep,name=Filter,proto3" json:"Filter,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *ListJobRequest) Reset()         { *m = ListJobRequest{} }
func (m *ListJobRequest) String() string { return proto.CompactTextString(m) }
func (*ListJobRequest) ProtoMessage()    {}
func (*ListJobRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{31}
}
func (m *ListJobRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListJobRequest.Unmarshal(m, b)
}
func (m *ListJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListJobRequest.Marshal(b, m, deterministic)
}
func (dst *ListJobRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListJobRequest.Merge(dst, src)
}
func (m *ListJobRequest) XXX_Size() int {
	return xxx_messageInfo_ListJobRequest.Size(m)
}
func (m *ListJobRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ListJobRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ListJobRequest proto.InternalMessageInfo

func (m *ListJobRequest) GetLimit() int32 {
	if m != nil {
		return m.Limit
	}
	return 0
}

func (m *ListJobRequest) GetOffset() int32 {
	if m != nil {
		return m.Offset
	}
	return 0
}

func (m *ListJobRequest) GetSortKeys() []string {
	if m != nil {
		return m.SortKeys
	}
	return nil
}

func (m *ListJobRequest) GetSortDirs() []string {
	if m != nil {
		return m.SortDirs
	}
	return nil
}

func (m *ListJobRequest) GetFilter() map[string]string {
	if m != nil {
		return m.Filter
	}
	return nil
}

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 (m *ListJobResponse) Reset()         { *m = ListJobResponse{} }
func (m *ListJobResponse) String() string { return proto.CompactTextString(m) }
func (*ListJobResponse) ProtoMessage()    {}
func (*ListJobResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_dataflow_63b5ce1c78fcbb67, []int{32}
}
func (m *ListJobResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListJobResponse.Unmarshal(m, b)
}
func (m *ListJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListJobResponse.Marshal(b, m, deterministic)
}
func (dst *ListJobResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListJobResponse.Merge(dst, src)
}
func (m *ListJobResponse) XXX_Size() int {
	return xxx_messageInfo_ListJobResponse.Size(m)
}
func (m *ListJobResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ListJobResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ListJobResponse proto.InternalMessageInfo

func (m *ListJobResponse) GetJobs() []*Job {
	if m != nil {
		return m.Jobs
	}
	return nil
}

func (m *ListJobResponse) GetNext() int32 {
	if m != nil {
		return m.Next
	}
	return 0
}

func init() {
	proto.RegisterType((*Schedule)(nil), "Schedule")
	proto.RegisterType((*Policy)(nil), "Policy")
	proto.RegisterType((*GetPolicyRequest)(nil), "GetPolicyRequest")
	proto.RegisterType((*GetPolicyResponse)(nil), "GetPolicyResponse")
	proto.RegisterType((*ListPolicyRequest)(nil), "ListPolicyRequest")
	proto.RegisterType((*ListPolicyResponse)(nil), "ListPolicyResponse")
	proto.RegisterType((*CreatePolicyRequest)(nil), "CreatePolicyRequest")
	proto.RegisterType((*CreatePolicyResponse)(nil), "CreatePolicyResponse")
	proto.RegisterType((*UpdatePolicyRequest)(nil), "UpdatePolicyRequest")
	proto.RegisterType((*UpdatePolicyResponse)(nil), "UpdatePolicyResponse")
	proto.RegisterType((*DeletePolicyRequest)(nil), "DeletePolicyRequest")
	proto.RegisterType((*DeletePolicyResponse)(nil), "DeletePolicyResponse")
	proto.RegisterType((*KV)(nil), "KV")
	proto.RegisterType((*Filter)(nil), "Filter")
	proto.RegisterType((*Connector)(nil), "Connector")
	proto.RegisterType((*Plan)(nil), "Plan")
	proto.RegisterType((*CreatePlanRequest)(nil), "CreatePlanRequest")
	proto.RegisterType((*CreatePlanResponse)(nil), "CreatePlanResponse")
	proto.RegisterType((*GetPlanRequest)(nil), "GetPlanRequest")
	proto.RegisterType((*GetPlanResponse)(nil), "GetPlanResponse")
	proto.RegisterType((*ListPlanRequest)(nil), "ListPlanRequest")
	proto.RegisterMapType((map[string]string)(nil), "ListPlanRequest.FilterEntry")
	proto.RegisterType((*ListPlanResponse)(nil), "ListPlanResponse")
	proto.RegisterType((*UpdatePlanRequest)(nil), "UpdatePlanRequest")
	proto.RegisterType((*UpdatePlanResponse)(nil), "UpdatePlanResponse")
	proto.RegisterType((*DeletePlanRequest)(nil), "DeletePlanRequest")
	proto.RegisterType((*DeletePlanResponse)(nil), "DeletePlanResponse")
	proto.RegisterType((*RunPlanRequest)(nil), "RunPlanRequest")
	proto.RegisterType((*RunPlanResponse)(nil), "RunPlanResponse")
	proto.RegisterType((*Job)(nil), "Job")
	proto.RegisterType((*GetJobRequest)(nil), "GetJobRequest")
	proto.RegisterType((*GetJobResponse)(nil), "GetJobResponse")
	proto.RegisterType((*ListJobRequest)(nil), "ListJobRequest")
	proto.RegisterMapType((map[string]string)(nil), "ListJobRequest.FilterEntry")
	proto.RegisterType((*ListJobResponse)(nil), "ListJobResponse")
}

func init() { proto.RegisterFile("dataflow.proto", fileDescriptor_dataflow_63b5ce1c78fcbb67) }

var fileDescriptor_dataflow_63b5ce1c78fcbb67 = []byte{
	// 1295 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x57, 0xe9, 0x6e, 0xdb, 0x46,
	0x10, 0xb6, 0x4e, 0x4b, 0x63, 0x5b, 0xc7, 0x48, 0x0e, 0x58, 0x26, 0x48, 0x84, 0xcd, 0x01, 0x23,
	0x2d, 0x16, 0x68, 0x12, 0x34, 0x4d, 0x80, 0x36, 0x08, 0x9c, 0x03, 0x8e, 0x83, 0x22, 0x60, 0xd2,
	0xfc, 0xa7, 0xc4, 0x95, 0xcb, 0x98, 0xe6, 0xaa, 0xe4, 0xaa, 0x89, 0x9e, 0xa2, 0x8f, 0x54, 0xf4,
	0x11, 0xfa, 0x12, 0x45, 0x1f, 0xa3, 0xd8, 0x83, 0xd4, 0x92, 0x94, 0x82, 0xc2, 0x08, 0xfa, 0x8f,
	0x73, 0xec, 0xec, 0xcc, 0xec, 0xcc, 0x37, 0x43, 0xe8, 0x05, 0xbe, 0xf0, 0xe7, 0x11, 0xff, 0x48,
	0x17, 0x09, 0x17, 0x9c, 0xbc, 0x82, 0xce, 0xdb, 0xd9, 0x2f, 0x2c, 0x58, 0x46, 0x0c, 0x11, 0x9a,
	0x62, 0xb5, 0x60, 0x4e, 0x6d, 0x52, 0x3b, 0xea, 0x7a, 0xea, 0x1b, 0xef, 0xc2, 0x40, 0x84, 0x67,
	0x67, 0x2c, 0x79, 0x93, 0xf0, 0x05, 0x4b, 0x44, 0xc8, 0x52, 0xa7, 0xae, 0xe4, 0x15, 0x3e, 0xf9,
	0xb3, 0x06, 0xed, 0x37, 0x3c, 0x0a, 0x67, 0x2b, 0xec, 0x41, 0x3d, 0x0c, 0x8c, 0xa1, 0x7a, 0x18,
	0xa0, 0x0b, 0x1d, 0xc1, 0x62, 0x3f, 0x16, 0x27, 0x81, 0x39, 0x9e, 0xd3, 0x78, 0x05, 0xda, 0xcb,
	0x94, 0x25, 0x27, 0x81, 0xd3, 0x50, 0x12, 0x43, 0x49, 0x77, 0x62, 0xff, 0x82, 0x39, 0x4d, 0xed,
	0x8e, 0xfc, 0x96, 0xba, 0xfa, 0x9c, 0xd3, 0xd2, 0xba, 0x9a, 0xc2, 0x09, 0xec, 0x05, 0x2c, 0x9d,
	0x25, 0xe1, 0x42, 0x84, 0x3c, 0x76, 0xda, 0x4a, 0x68, 0xb3, 0xf0, 0x36, 0x74, 0x52, 0x13, 0xa8,
	0xb3, 0x3b, 0xa9, 0x1d, 0xed, 0xdd, 0xeb, 0xd2, 0x2c, 0x72, 0x2f, 0x17, 0x11, 0x02, 0x83, 0x97,
	0x4c, 0xe8, 0x28, 0x3c, 0xf6, 0xeb, 0x92, 0xa5, 0xa2, 0x1c, 0x0c, 0x79, 0x01, 0x43, 0x4b, 0x27,
	0x5d, 0xf0, 0x38, 0x65, 0x38, 0x80, 0x06, 0x4b, 0x12, 0xa3, 0x25, 0x3f, 0xf1, 0x06, 0xb4, 0x17,
	0x4a, 0x47, 0x45, 0xbc, 0x77, 0x6f, 0x97, 0x9a, 0x23, 0x86, 0x4d, 0x46, 0x30, 0x7c, 0x1d, 0xa6,
	0xc5, 0xcb, 0xc8, 0x29, 0xa0, 0xcd, 0xdc, 0x6a, 0xfd, 0x26, 0x74, 0x94, 0x19, 0xfd, 0x20, 0x0d,
	0xdb, 0x7e, 0x2e, 0x20, 0xdf, 0xc1, 0xe8, 0x38, 0x61, 0xbe, 0x60, 0xc5, 0x80, 0xd6, 0x9e, 0xd5,
	0x36, 0x7b, 0x76, 0x02, 0xe3, 0xe2, 0xb9, 0xcb, 0x07, 0xf9, 0x1c, 0x46, 0x3f, 0x2f, 0x82, 0x8a,
	0x0b, 0xae, 0x71, 0x7f, 0x75, 0x92, 0x65, 0x36, 0xa7, 0xe5, 0xc3, 0x4f, 0x79, 0xb0, 0x32, 0x85,
	0xa2, 0xbe, 0xa5, 0x47, 0x45, 0x33, 0x97, 0xf7, 0xe8, 0x36, 0x8c, 0x9e, 0xb1, 0x88, 0x95, 0x3d,
	0x2a, 0xbf, 0xf2, 0x11, 0x8c, 0x8b, 0x6a, 0xdb, 0x6e, 0x24, 0xdf, 0x40, 0xfd, 0xf4, 0xbd, 0xe4,
	0x9f, 0xb3, 0x55, 0xc6, 0x3f, 0x67, 0x2b, 0x1c, 0x43, 0xeb, 0x37, 0x3f, 0x5a, 0x32, 0x13, 0x88,
	0x26, 0xc8, 0x43, 0x68, 0xbf, 0x08, 0x23, 0xc1, 0x12, 0x59, 0xcc, 0x8b, 0x84, 0xcd, 0xc3, 0x4f,
	0xe6, 0x90, 0xa1, 0xf0, 0x10, 0x1a, 0xc2, 0x3f, 0x33, 0xaf, 0xda, 0xa0, 0xa7, 0xef, 0x3d, 0x49,
	0x93, 0x08, 0xba, 0xc7, 0x3c, 0x8e, 0xd9, 0x4c, 0xf0, 0x44, 0xe6, 0x2f, 0x15, 0x3c, 0x79, 0xb7,
	0xee, 0xd7, 0x9c, 0xc6, 0xeb, 0x00, 0xd3, 0xe5, 0xec, 0x9c, 0x89, 0x9f, 0x64, 0xfb, 0xe8, 0xcb,
	0x2d, 0x0e, 0xde, 0x04, 0x98, 0xf1, 0x38, 0x3e, 0xe6, 0xf1, 0x3c, 0x3c, 0x73, 0x1a, 0xeb, 0x6b,
	0x2c, 0x36, 0xf9, 0xbd, 0x01, 0xcd, 0x37, 0x91, 0x1f, 0x57, 0x5a, 0x39, 0x6b, 0xcb, 0xba, 0xd5,
	0x96, 0xa5, 0xf6, 0x6b, 0x54, 0xdb, 0x2f, 0xc3, 0x96, 0xa6, 0x85, 0x2d, 0x76, 0x0d, 0xb4, 0x4a,
	0x35, 0x70, 0x1d, 0x40, 0x7f, 0xab, 0x18, 0x74, 0x3f, 0x5b, 0x1c, 0xbc, 0x0b, 0x90, 0xf2, 0x65,
	0x32, 0x63, 0x32, 0x25, 0xa6, 0xa1, 0x81, 0xe6, 0xf9, 0xf1, 0x2c, 0x29, 0xde, 0x81, 0x4e, 0xc0,
	0x52, 0xa1, 0x34, 0x3b, 0x15, 0xcd, 0x5c, 0x26, 0x2b, 0x67, 0xae, 0x5e, 0xc6, 0xe9, 0x9a, 0xca,
	0xd1, 0x0f, 0xe5, 0x19, 0x36, 0x12, 0xd8, 0x4f, 0xd8, 0x85, 0x1f, 0xc6, 0x6f, 0x95, 0x71, 0x07,
	0x26, 0xb5, 0xa3, 0x8e, 0x57, 0xe0, 0x15, 0x90, 0x6e, 0x6f, 0x2b, 0xd2, 0xed, 0x17, 0x90, 0xee,
	0x16, 0x1c, 0xe8, 0xd0, 0x9e, 0xc7, 0xfe, 0x34, 0x62, 0x81, 0x73, 0xa0, 0x0c, 0x17, 0x99, 0x84,
	0xc2, 0xd0, 0x34, 0x65, 0xe4, 0xc7, 0x59, 0xd5, 0x7e, 0x05, 0xcd, 0x45, 0xe4, 0xc7, 0xa6, 0x91,
	0x5b, 0x54, 0xc9, 0x14, 0x8b, 0x3c, 0x05, 0xb4, 0xf5, 0xb7, 0x36, 0x4c, 0x66, 0xa2, 0x5e, 0x35,
	0x31, 0x81, 0x9e, 0x44, 0x3a, 0xeb, 0xbe, 0x72, 0x97, 0xfc, 0x08, 0xfd, 0x5c, 0xe3, 0x32, 0x37,
	0xfc, 0x53, 0x83, 0xbe, 0xc2, 0x3b, 0xeb, 0x8e, 0x31, 0xb4, 0xa2, 0xf0, 0x22, 0x14, 0xca, 0x44,
	0xcb, 0xd3, 0x84, 0x4c, 0x1e, 0x9f, 0xcf, 0x53, 0x26, 0x94, 0x99, 0x96, 0x67, 0x28, 0xd5, 0x09,
	0x3c, 0x11, 0xa7, 0x6c, 0x95, 0xaa, 0x5a, 0x96, 0x9d, 0x60, 0xe8, 0x4c, 0xf6, 0x2c, 0x4c, 0x52,
	0xa7, 0xb9, 0x96, 0x49, 0x1a, 0x1f, 0x64, 0x7d, 0xe8, 0xb4, 0x54, 0x07, 0x5c, 0xa3, 0x25, 0x3f,
	0xcc, 0xeb, 0x3f, 0x8f, 0x45, 0xb2, 0xf2, 0x8c, 0xae, 0xfb, 0x08, 0xf6, 0x2c, 0xf6, 0x7f, 0x6d,
	0xfa, 0xc7, 0xf5, 0xef, 0x6b, 0xe4, 0x18, 0x06, 0xeb, 0x1b, 0x4c, 0xae, 0xae, 0x42, 0x4b, 0xa6,
	0x21, 0x75, 0x6a, 0xca, 0x07, 0x93, 0x1a, 0xcd, 0x53, 0x9d, 0xc6, 0x3e, 0x65, 0xf1, 0xaa, 0x6f,
	0xf2, 0x04, 0x86, 0x06, 0x07, 0xad, 0x84, 0x49, 0x20, 0x89, 0xfc, 0x38, 0x87, 0x52, 0x43, 0x6d,
	0x04, 0xd2, 0xa7, 0x80, 0xb6, 0x81, 0xcb, 0xbc, 0xd9, 0x4d, 0x18, 0x1a, 0x64, 0xfc, 0x4c, 0x61,
	0xdc, 0x01, 0xb4, 0x95, 0xb6, 0x82, 0xe7, 0x04, 0x7a, 0xde, 0x32, 0xfe, 0x9c, 0xa5, 0x47, 0xd0,
	0xcf, 0x35, 0xb6, 0xba, 0x3b, 0x86, 0xd6, 0x07, 0x3e, 0xcd, 0xb7, 0x0b, 0x4d, 0x90, 0x3f, 0x9a,
	0xd0, 0x78, 0xc5, 0xa7, 0x5f, 0x6a, 0x1d, 0xd9, 0x88, 0x60, 0x91, 0x1f, 0x2b, 0x8c, 0xca, 0x10,
	0xcc, 0xd0, 0xd6, 0xa3, 0xb4, 0x0b, 0x8f, 0x52, 0xc2, 0xca, 0xdd, 0x2a, 0x56, 0xde, 0x81, 0x9e,
	0x46, 0xaf, 0xd7, 0x7c, 0xe6, 0x2b, 0xa5, 0x8e, 0x52, 0x2a, 0x71, 0x25, 0x1c, 0x49, 0xec, 0xca,
	0xb5, 0xba, 0x4a, 0xab, 0xc0, 0x93, 0x5e, 0xa4, 0xc2, 0x17, 0xcb, 0x54, 0x81, 0x55, 0xd7, 0x33,
	0x94, 0xc4, 0xd7, 0x99, 0x02, 0x87, 0x77, 0xe1, 0x05, 0x53, 0x40, 0xd5, 0xf0, 0x2c, 0x0e, 0x5e,
	0x83, 0x6e, 0x2a, 0xfc, 0x44, 0x28, 0xf1, 0xbe, 0x12, 0xaf, 0x19, 0xe8, 0xc0, 0x2e, 0x8b, 0x03,
	0x25, 0x3b, 0x50, 0xb2, 0x8c, 0xac, 0x40, 0x64, 0x6f, 0x03, 0x44, 0xde, 0x82, 0x03, 0xc1, 0x85,
	0x1f, 0x1d, 0xfb, 0x0b, 0x7f, 0x16, 0x8a, 0x95, 0xd3, 0x57, 0x36, 0x8a, 0x4c, 0x99, 0x85, 0x85,
	0x9f, 0xa6, 0x2c, 0xc8, 0xd5, 0x06, 0x4a, 0xad, 0xc4, 0x95, 0x91, 0xe8, 0x83, 0x7c, 0x19, 0x0b,
	0x67, 0xa8, 0x23, 0x59, 0x73, 0x64, 0xbe, 0xcd, 0x09, 0xa5, 0x80, 0x4a, 0xc1, 0x66, 0xa9, 0x57,
	0x4c, 0xf8, 0x59, 0xc2, 0xd2, 0xd4, 0x19, 0x29, 0x71, 0x4e, 0x93, 0x1b, 0x70, 0xf0, 0x92, 0x89,
	0x57, 0x7c, 0xba, 0xad, 0x3a, 0x1f, 0x2b, 0x88, 0x54, 0x0a, 0x5b, 0x8b, 0xf3, 0x0a, 0x34, 0x3e,
	0xf0, 0xa9, 0x69, 0xa5, 0x26, 0x95, 0xca, 0x92, 0x41, 0xfe, 0xae, 0x41, 0x4f, 0x42, 0x82, 0x65,
	0xfe, 0xff, 0xc1, 0xbe, 0xfb, 0x25, 0xec, 0xbb, 0x4a, 0x8b, 0x6e, 0x7c, 0x69, 0xe8, 0x7b, 0xa2,
	0x41, 0xde, 0xce, 0x92, 0x03, 0xcd, 0x0f, 0x7c, 0x9a, 0x01, 0x9f, 0x4e, 0x8a, 0xe2, 0x6c, 0x82,
	0xbd, 0x7b, 0x7f, 0xb5, 0xa0, 0xf3, 0xcc, 0x17, 0xfe, 0x8b, 0x88, 0x7f, 0xc4, 0x07, 0xd0, 0xcd,
	0xf7, 0x6f, 0x1c, 0xd2, 0xf2, 0xbe, 0xee, 0x22, 0xad, 0xac, 0xe7, 0x64, 0x07, 0x1f, 0x02, 0xac,
	0x17, 0x6b, 0x44, 0x5a, 0x59, 0xbd, 0xdd, 0x11, 0xad, 0x6e, 0xde, 0x64, 0x07, 0x7f, 0x80, 0x7d,
	0x7b, 0x19, 0xc6, 0x31, 0xdd, 0xb0, 0x53, 0xbb, 0x87, 0x74, 0xd3, 0xc6, 0xac, 0x8f, 0xdb, 0x9b,
	0x2b, 0x8e, 0xe9, 0x86, 0x7d, 0xd8, 0x3d, 0xa4, 0x9b, 0xd6, 0x5b, 0x7d, 0xdc, 0x5e, 0x43, 0x71,
	0x4c, 0x37, 0x2c, 0xaf, 0xee, 0x21, 0xdd, 0xb4, 0xab, 0x92, 0x1d, 0xa4, 0xb0, 0x6b, 0xe6, 0x33,
	0xf6, 0x69, 0x71, 0x96, 0xbb, 0x03, 0x5a, 0x1a, 0xdd, 0x64, 0x07, 0xbf, 0x85, 0x4e, 0x36, 0xa4,
	0x70, 0x50, 0x9e, 0x88, 0xee, 0x90, 0x96, 0x27, 0x98, 0x4e, 0xec, 0x7a, 0xcf, 0x40, 0xa4, 0x95,
	0x25, 0xc5, 0x1d, 0xd1, 0xea, 0x22, 0xa2, 0x0f, 0xae, 0x47, 0x11, 0x22, 0xad, 0x0c, 0x36, 0x77,
	0x44, 0xab, 0xb3, 0x4a, 0x1f, 0x5c, 0xcf, 0x16, 0x44, 0x5a, 0x99, 0x46, 0xee, 0x88, 0x56, 0x87,
	0x0f, 0xd9, 0xc1, 0xaf, 0xa1, 0xad, 0x9b, 0x15, 0x7b, 0xb4, 0xd0, 0xd6, 0x6e, 0x9f, 0x16, 0xbb,
	0x58, 0xa7, 0xce, 0x14, 0x2d, 0xf6, 0x4b, 0xfd, 0xe1, 0x0e, 0x68, 0xa9, 0x9e, 0xb5, 0xbe, 0x99,
	0x53, 0xd8, 0xa7, 0xc5, 0x99, 0xe6, 0x0e, 0x68, 0x69, 0x84, 0x91, 0x9d, 0x69, 0x5b, 0xfd, 0x81,
	0xdf, 0xff, 0x37, 0x00, 0x00, 0xff, 0xff, 0x7d, 0xe7, 0xed, 0xfe, 0x93, 0x0f, 0x00, 0x00,
}