Versions in this module Expand all Collapse all v0 v0.5.0 Feb 2, 2019 v0.4.0 Dec 7, 2018 v0.3.4 Dec 7, 2018 v0.3.3 Nov 30, 2018 v0.3.2 Nov 9, 2018 Changes in this version + func RegisterDataFlowHandler(s server.Server, hdlr DataFlowHandler, opts ...server.HandlerOption) error + type Connector struct + BucketName string + ConnConfig []*KV + StorType string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Connector) Descriptor() ([]byte, []int) + func (*Connector) ProtoMessage() + func (dst *Connector) XXX_Merge(src proto.Message) + func (m *Connector) GetBucketName() string + func (m *Connector) GetConnConfig() []*KV + func (m *Connector) GetStorType() string + func (m *Connector) Reset() + func (m *Connector) String() string + func (m *Connector) XXX_DiscardUnknown() + func (m *Connector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Connector) XXX_Size() int + func (m *Connector) XXX_Unmarshal(b []byte) error + type CreatePlanRequest struct + Context string + Plan *Plan + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreatePlanRequest) Descriptor() ([]byte, []int) + func (*CreatePlanRequest) ProtoMessage() + func (dst *CreatePlanRequest) XXX_Merge(src proto.Message) + func (m *CreatePlanRequest) GetContext() string + func (m *CreatePlanRequest) GetPlan() *Plan + func (m *CreatePlanRequest) Reset() + func (m *CreatePlanRequest) String() string + func (m *CreatePlanRequest) XXX_DiscardUnknown() + func (m *CreatePlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreatePlanRequest) XXX_Size() int + func (m *CreatePlanRequest) XXX_Unmarshal(b []byte) error + type CreatePlanResponse struct + Err string + Plan *Plan + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreatePlanResponse) Descriptor() ([]byte, []int) + func (*CreatePlanResponse) ProtoMessage() + func (dst *CreatePlanResponse) XXX_Merge(src proto.Message) + func (m *CreatePlanResponse) GetErr() string + func (m *CreatePlanResponse) GetPlan() *Plan + func (m *CreatePlanResponse) Reset() + func (m *CreatePlanResponse) String() string + func (m *CreatePlanResponse) XXX_DiscardUnknown() + func (m *CreatePlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreatePlanResponse) XXX_Size() int + func (m *CreatePlanResponse) XXX_Unmarshal(b []byte) error + type CreatePolicyRequest struct + Context string + Policy *Policy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreatePolicyRequest) Descriptor() ([]byte, []int) + func (*CreatePolicyRequest) ProtoMessage() + func (dst *CreatePolicyRequest) XXX_Merge(src proto.Message) + func (m *CreatePolicyRequest) GetContext() string + func (m *CreatePolicyRequest) GetPolicy() *Policy + func (m *CreatePolicyRequest) Reset() + func (m *CreatePolicyRequest) String() string + func (m *CreatePolicyRequest) XXX_DiscardUnknown() + func (m *CreatePolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreatePolicyRequest) XXX_Size() int + func (m *CreatePolicyRequest) XXX_Unmarshal(b []byte) error + type CreatePolicyResponse struct + Err string + Policy *Policy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreatePolicyResponse) Descriptor() ([]byte, []int) + func (*CreatePolicyResponse) ProtoMessage() + func (dst *CreatePolicyResponse) XXX_Merge(src proto.Message) + func (m *CreatePolicyResponse) GetErr() string + func (m *CreatePolicyResponse) GetPolicy() *Policy + func (m *CreatePolicyResponse) Reset() + func (m *CreatePolicyResponse) String() string + func (m *CreatePolicyResponse) XXX_DiscardUnknown() + func (m *CreatePolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreatePolicyResponse) XXX_Size() int + func (m *CreatePolicyResponse) XXX_Unmarshal(b []byte) error + type DataFlowHandler interface + CreatePlan func(context.Context, *CreatePlanRequest, *CreatePlanResponse) error + CreatePolicy func(context.Context, *CreatePolicyRequest, *CreatePolicyResponse) error + DeletePlan func(context.Context, *DeletePlanRequest, *DeletePlanResponse) error + DeletePolicy func(context.Context, *DeletePolicyRequest, *DeletePolicyResponse) error + GetJob func(context.Context, *GetJobRequest, *GetJobResponse) error + GetPlan func(context.Context, *GetPlanRequest, *GetPlanResponse) error + GetPolicy func(context.Context, *GetPolicyRequest, *GetPolicyResponse) error + ListJob func(context.Context, *ListJobRequest, *ListJobResponse) error + ListPlan func(context.Context, *ListPlanRequest, *ListPlanResponse) error + ListPolicy func(context.Context, *ListPolicyRequest, *ListPolicyResponse) error + RunPlan func(context.Context, *RunPlanRequest, *RunPlanResponse) error + UpdatePlan func(context.Context, *UpdatePlanRequest, *UpdatePlanResponse) error + UpdatePolicy func(context.Context, *UpdatePolicyRequest, *UpdatePolicyResponse) error + type DataFlowService interface + CreatePlan func(ctx context.Context, in *CreatePlanRequest, opts ...client.CallOption) (*CreatePlanResponse, error) + CreatePolicy func(ctx context.Context, in *CreatePolicyRequest, opts ...client.CallOption) (*CreatePolicyResponse, error) + DeletePlan func(ctx context.Context, in *DeletePlanRequest, opts ...client.CallOption) (*DeletePlanResponse, error) + DeletePolicy func(ctx context.Context, in *DeletePolicyRequest, opts ...client.CallOption) (*DeletePolicyResponse, error) + GetJob func(ctx context.Context, in *GetJobRequest, opts ...client.CallOption) (*GetJobResponse, error) + GetPlan func(ctx context.Context, in *GetPlanRequest, opts ...client.CallOption) (*GetPlanResponse, error) + GetPolicy func(ctx context.Context, in *GetPolicyRequest, opts ...client.CallOption) (*GetPolicyResponse, error) + ListJob func(ctx context.Context, in *ListJobRequest, opts ...client.CallOption) (*ListJobResponse, error) + ListPlan func(ctx context.Context, in *ListPlanRequest, opts ...client.CallOption) (*ListPlanResponse, error) + ListPolicy func(ctx context.Context, in *ListPolicyRequest, opts ...client.CallOption) (*ListPolicyResponse, error) + RunPlan func(ctx context.Context, in *RunPlanRequest, opts ...client.CallOption) (*RunPlanResponse, error) + UpdatePlan func(ctx context.Context, in *UpdatePlanRequest, opts ...client.CallOption) (*UpdatePlanResponse, error) + UpdatePolicy func(ctx context.Context, in *UpdatePolicyRequest, opts ...client.CallOption) (*UpdatePolicyResponse, error) + func NewDataFlowService(name string, c client.Client) DataFlowService + type DeletePlanRequest struct + Context string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeletePlanRequest) Descriptor() ([]byte, []int) + func (*DeletePlanRequest) ProtoMessage() + func (dst *DeletePlanRequest) XXX_Merge(src proto.Message) + func (m *DeletePlanRequest) GetContext() string + func (m *DeletePlanRequest) GetId() string + func (m *DeletePlanRequest) Reset() + func (m *DeletePlanRequest) String() string + func (m *DeletePlanRequest) XXX_DiscardUnknown() + func (m *DeletePlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeletePlanRequest) XXX_Size() int + func (m *DeletePlanRequest) XXX_Unmarshal(b []byte) error + type DeletePlanResponse struct + Err string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeletePlanResponse) Descriptor() ([]byte, []int) + func (*DeletePlanResponse) ProtoMessage() + func (dst *DeletePlanResponse) XXX_Merge(src proto.Message) + func (m *DeletePlanResponse) GetErr() string + func (m *DeletePlanResponse) Reset() + func (m *DeletePlanResponse) String() string + func (m *DeletePlanResponse) XXX_DiscardUnknown() + func (m *DeletePlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeletePlanResponse) XXX_Size() int + func (m *DeletePlanResponse) XXX_Unmarshal(b []byte) error + type DeletePolicyRequest struct + Context string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeletePolicyRequest) Descriptor() ([]byte, []int) + func (*DeletePolicyRequest) ProtoMessage() + func (dst *DeletePolicyRequest) XXX_Merge(src proto.Message) + func (m *DeletePolicyRequest) GetContext() string + func (m *DeletePolicyRequest) GetId() string + func (m *DeletePolicyRequest) Reset() + func (m *DeletePolicyRequest) String() string + func (m *DeletePolicyRequest) XXX_DiscardUnknown() + func (m *DeletePolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeletePolicyRequest) XXX_Size() int + func (m *DeletePolicyRequest) XXX_Unmarshal(b []byte) error + type DeletePolicyResponse struct + Err string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeletePolicyResponse) Descriptor() ([]byte, []int) + func (*DeletePolicyResponse) ProtoMessage() + func (dst *DeletePolicyResponse) XXX_Merge(src proto.Message) + func (m *DeletePolicyResponse) GetErr() string + func (m *DeletePolicyResponse) Reset() + func (m *DeletePolicyResponse) String() string + func (m *DeletePolicyResponse) XXX_DiscardUnknown() + func (m *DeletePolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeletePolicyResponse) XXX_Size() int + func (m *DeletePolicyResponse) XXX_Unmarshal(b []byte) error + type Filter struct + Prefix string + Tag []*KV + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Filter) Descriptor() ([]byte, []int) + func (*Filter) ProtoMessage() + func (dst *Filter) XXX_Merge(src proto.Message) + func (m *Filter) GetPrefix() string + func (m *Filter) GetTag() []*KV + func (m *Filter) Reset() + func (m *Filter) String() string + func (m *Filter) XXX_DiscardUnknown() + func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Filter) XXX_Size() int + func (m *Filter) XXX_Unmarshal(b []byte) error + type GetJobRequest struct + Context string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetJobRequest) Descriptor() ([]byte, []int) + func (*GetJobRequest) ProtoMessage() + func (dst *GetJobRequest) XXX_Merge(src proto.Message) + func (m *GetJobRequest) GetContext() string + func (m *GetJobRequest) GetId() string + func (m *GetJobRequest) Reset() + func (m *GetJobRequest) String() string + func (m *GetJobRequest) XXX_DiscardUnknown() + func (m *GetJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetJobRequest) XXX_Size() int + func (m *GetJobRequest) XXX_Unmarshal(b []byte) error + type GetJobResponse struct + Err string + Job *Job + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetJobResponse) Descriptor() ([]byte, []int) + func (*GetJobResponse) ProtoMessage() + func (dst *GetJobResponse) XXX_Merge(src proto.Message) + func (m *GetJobResponse) GetErr() string + func (m *GetJobResponse) GetJob() *Job + func (m *GetJobResponse) Reset() + func (m *GetJobResponse) String() string + func (m *GetJobResponse) XXX_DiscardUnknown() + func (m *GetJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetJobResponse) XXX_Size() int + func (m *GetJobResponse) XXX_Unmarshal(b []byte) error + type GetPlanRequest struct + Context string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetPlanRequest) Descriptor() ([]byte, []int) + func (*GetPlanRequest) ProtoMessage() + func (dst *GetPlanRequest) XXX_Merge(src proto.Message) + func (m *GetPlanRequest) GetContext() string + func (m *GetPlanRequest) GetId() string + func (m *GetPlanRequest) Reset() + func (m *GetPlanRequest) String() string + func (m *GetPlanRequest) XXX_DiscardUnknown() + func (m *GetPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetPlanRequest) XXX_Size() int + func (m *GetPlanRequest) XXX_Unmarshal(b []byte) error + type GetPlanResponse struct + Err string + Plan *Plan + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetPlanResponse) Descriptor() ([]byte, []int) + func (*GetPlanResponse) ProtoMessage() + func (dst *GetPlanResponse) XXX_Merge(src proto.Message) + func (m *GetPlanResponse) GetErr() string + func (m *GetPlanResponse) GetPlan() *Plan + func (m *GetPlanResponse) Reset() + func (m *GetPlanResponse) String() string + func (m *GetPlanResponse) XXX_DiscardUnknown() + func (m *GetPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetPlanResponse) XXX_Size() int + func (m *GetPlanResponse) XXX_Unmarshal(b []byte) error + type GetPolicyRequest struct + Context string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetPolicyRequest) Descriptor() ([]byte, []int) + func (*GetPolicyRequest) ProtoMessage() + func (dst *GetPolicyRequest) XXX_Merge(src proto.Message) + func (m *GetPolicyRequest) GetContext() string + func (m *GetPolicyRequest) GetId() string + func (m *GetPolicyRequest) Reset() + func (m *GetPolicyRequest) String() string + func (m *GetPolicyRequest) XXX_DiscardUnknown() + func (m *GetPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetPolicyRequest) XXX_Size() int + func (m *GetPolicyRequest) XXX_Unmarshal(b []byte) error + type GetPolicyResponse struct + Err string + Policy *Policy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetPolicyResponse) Descriptor() ([]byte, []int) + func (*GetPolicyResponse) ProtoMessage() + func (dst *GetPolicyResponse) XXX_Merge(src proto.Message) + func (m *GetPolicyResponse) GetErr() string + func (m *GetPolicyResponse) GetPolicy() *Policy + func (m *GetPolicyResponse) Reset() + func (m *GetPolicyResponse) String() string + func (m *GetPolicyResponse) XXX_DiscardUnknown() + func (m *GetPolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetPolicyResponse) XXX_Size() int + func (m *GetPolicyResponse) XXX_Unmarshal(b []byte) error + type Job struct + CreateTime int64 + Description string + DestLocation string + EndTime int64 + Id string + PassedCapacity int64 + PassedCount int64 + PlanId string + PlanName string + Progress int64 + RemainSource bool + SourceLocation string + StartTime int64 + Status string + TotalCapacity int64 + TotalCount int64 + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (dst *Job) XXX_Merge(src proto.Message) + func (m *Job) GetCreateTime() int64 + func (m *Job) GetDescription() string + func (m *Job) GetDestLocation() string + func (m *Job) GetEndTime() int64 + func (m *Job) GetId() string + func (m *Job) GetPassedCapacity() int64 + func (m *Job) GetPassedCount() int64 + func (m *Job) GetPlanId() string + func (m *Job) GetPlanName() string + func (m *Job) GetProgress() int64 + func (m *Job) GetRemainSource() bool + func (m *Job) GetSourceLocation() string + func (m *Job) GetStartTime() int64 + func (m *Job) GetStatus() string + func (m *Job) GetTotalCapacity() int64 + func (m *Job) GetTotalCount() int64 + func (m *Job) GetType() string + func (m *Job) Reset() + func (m *Job) String() string + func (m *Job) XXX_DiscardUnknown() + func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Job) XXX_Size() int + func (m *Job) XXX_Unmarshal(b []byte) error + type KV struct + Key string + Value string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KV) Descriptor() ([]byte, []int) + func (*KV) ProtoMessage() + func (dst *KV) XXX_Merge(src proto.Message) + func (m *KV) GetKey() string + func (m *KV) GetValue() string + func (m *KV) Reset() + func (m *KV) String() string + func (m *KV) XXX_DiscardUnknown() + func (m *KV) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KV) XXX_Size() int + func (m *KV) XXX_Unmarshal(b []byte) error + type ListJobRequest struct + Context string + Filter map[string]string + Limit int32 + Offset int32 + SortDirs []string + SortKeys []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListJobRequest) Descriptor() ([]byte, []int) + func (*ListJobRequest) ProtoMessage() + func (dst *ListJobRequest) XXX_Merge(src proto.Message) + func (m *ListJobRequest) GetContext() string + func (m *ListJobRequest) GetFilter() map[string]string + func (m *ListJobRequest) GetLimit() int32 + func (m *ListJobRequest) GetOffset() int32 + func (m *ListJobRequest) GetSortDirs() []string + func (m *ListJobRequest) GetSortKeys() []string + func (m *ListJobRequest) Reset() + func (m *ListJobRequest) String() string + func (m *ListJobRequest) XXX_DiscardUnknown() + func (m *ListJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListJobRequest) XXX_Size() int + func (m *ListJobRequest) XXX_Unmarshal(b []byte) error + type ListJobResponse struct + Jobs []*Job + Next int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListJobResponse) Descriptor() ([]byte, []int) + func (*ListJobResponse) ProtoMessage() + func (dst *ListJobResponse) XXX_Merge(src proto.Message) + func (m *ListJobResponse) GetJobs() []*Job + func (m *ListJobResponse) GetNext() int32 + func (m *ListJobResponse) Reset() + func (m *ListJobResponse) String() string + func (m *ListJobResponse) XXX_DiscardUnknown() + func (m *ListJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListJobResponse) XXX_Size() int + func (m *ListJobResponse) XXX_Unmarshal(b []byte) error + type ListPlanRequest struct + Context string + Filter map[string]string + Limit int32 + Offset int32 + SortDirs []string + SortKeys []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListPlanRequest) Descriptor() ([]byte, []int) + func (*ListPlanRequest) ProtoMessage() + func (dst *ListPlanRequest) XXX_Merge(src proto.Message) + func (m *ListPlanRequest) GetContext() string + func (m *ListPlanRequest) GetFilter() map[string]string + func (m *ListPlanRequest) GetLimit() int32 + func (m *ListPlanRequest) GetOffset() int32 + func (m *ListPlanRequest) GetSortDirs() []string + func (m *ListPlanRequest) GetSortKeys() []string + func (m *ListPlanRequest) Reset() + func (m *ListPlanRequest) String() string + func (m *ListPlanRequest) XXX_DiscardUnknown() + func (m *ListPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPlanRequest) XXX_Size() int + func (m *ListPlanRequest) XXX_Unmarshal(b []byte) error + type ListPlanResponse struct + Next int32 + Plans []*Plan + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListPlanResponse) Descriptor() ([]byte, []int) + func (*ListPlanResponse) ProtoMessage() + func (dst *ListPlanResponse) XXX_Merge(src proto.Message) + func (m *ListPlanResponse) GetNext() int32 + func (m *ListPlanResponse) GetPlans() []*Plan + func (m *ListPlanResponse) Reset() + func (m *ListPlanResponse) String() string + func (m *ListPlanResponse) XXX_DiscardUnknown() + func (m *ListPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPlanResponse) XXX_Size() int + func (m *ListPlanResponse) XXX_Unmarshal(b []byte) error + type ListPolicyRequest struct + Context string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListPolicyRequest) Descriptor() ([]byte, []int) + func (*ListPolicyRequest) ProtoMessage() + func (dst *ListPolicyRequest) XXX_Merge(src proto.Message) + func (m *ListPolicyRequest) GetContext() string + func (m *ListPolicyRequest) Reset() + func (m *ListPolicyRequest) String() string + func (m *ListPolicyRequest) XXX_DiscardUnknown() + func (m *ListPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPolicyRequest) XXX_Size() int + func (m *ListPolicyRequest) XXX_Unmarshal(b []byte) error + type ListPolicyResponse struct + Err string + Policies []*Policy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListPolicyResponse) Descriptor() ([]byte, []int) + func (*ListPolicyResponse) ProtoMessage() + func (dst *ListPolicyResponse) XXX_Merge(src proto.Message) + func (m *ListPolicyResponse) GetErr() string + func (m *ListPolicyResponse) GetPolicies() []*Policy + func (m *ListPolicyResponse) Reset() + func (m *ListPolicyResponse) String() string + func (m *ListPolicyResponse) XXX_DiscardUnknown() + func (m *ListPolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPolicyResponse) XXX_Size() int + func (m *ListPolicyResponse) XXX_Unmarshal(b []byte) error + type Plan struct + Description string + DestConn *Connector + Filter *Filter + Id string + Name string + PolicyEnabled bool + PolicyId string + PolicyName string + RemainSource bool + SourceConn *Connector + TenantId string + Type string + UserId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Plan) Descriptor() ([]byte, []int) + func (*Plan) ProtoMessage() + func (dst *Plan) XXX_Merge(src proto.Message) + func (m *Plan) GetDescription() string + func (m *Plan) GetDestConn() *Connector + func (m *Plan) GetFilter() *Filter + func (m *Plan) GetId() string + func (m *Plan) GetName() string + func (m *Plan) GetPolicyEnabled() bool + func (m *Plan) GetPolicyId() string + func (m *Plan) GetPolicyName() string + func (m *Plan) GetRemainSource() bool + func (m *Plan) GetSourceConn() *Connector + func (m *Plan) GetTenantId() string + func (m *Plan) GetType() string + func (m *Plan) GetUserId() string + func (m *Plan) Reset() + func (m *Plan) String() string + func (m *Plan) XXX_DiscardUnknown() + func (m *Plan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Plan) XXX_Size() int + func (m *Plan) XXX_Unmarshal(b []byte) error + type Policy struct + Description string + Id string + Name string + Schedule *Schedule + Tenant string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Policy) Descriptor() ([]byte, []int) + func (*Policy) ProtoMessage() + func (dst *Policy) XXX_Merge(src proto.Message) + func (m *Policy) GetDescription() string + func (m *Policy) GetId() string + func (m *Policy) GetName() string + func (m *Policy) GetSchedule() *Schedule + func (m *Policy) GetTenant() string + func (m *Policy) Reset() + func (m *Policy) String() string + func (m *Policy) XXX_DiscardUnknown() + func (m *Policy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Policy) XXX_Size() int + func (m *Policy) XXX_Unmarshal(b []byte) error + type RunPlanRequest struct + Context string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RunPlanRequest) Descriptor() ([]byte, []int) + func (*RunPlanRequest) ProtoMessage() + func (dst *RunPlanRequest) XXX_Merge(src proto.Message) + func (m *RunPlanRequest) GetContext() string + func (m *RunPlanRequest) GetId() string + func (m *RunPlanRequest) Reset() + func (m *RunPlanRequest) String() string + func (m *RunPlanRequest) XXX_DiscardUnknown() + func (m *RunPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RunPlanRequest) XXX_Size() int + func (m *RunPlanRequest) XXX_Unmarshal(b []byte) error + type RunPlanResponse struct + Err string + JobId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RunPlanResponse) Descriptor() ([]byte, []int) + func (*RunPlanResponse) ProtoMessage() + func (dst *RunPlanResponse) XXX_Merge(src proto.Message) + func (m *RunPlanResponse) GetErr() string + func (m *RunPlanResponse) GetJobId() string + func (m *RunPlanResponse) Reset() + func (m *RunPlanResponse) String() string + func (m *RunPlanResponse) XXX_DiscardUnknown() + func (m *RunPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RunPlanResponse) XXX_Size() int + func (m *RunPlanResponse) XXX_Unmarshal(b []byte) error + type Schedule struct + TiggerProperties string + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Schedule) Descriptor() ([]byte, []int) + func (*Schedule) ProtoMessage() + func (dst *Schedule) XXX_Merge(src proto.Message) + func (m *Schedule) GetTiggerProperties() string + func (m *Schedule) GetType() string + func (m *Schedule) Reset() + func (m *Schedule) String() string + func (m *Schedule) XXX_DiscardUnknown() + func (m *Schedule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Schedule) XXX_Size() int + func (m *Schedule) XXX_Unmarshal(b []byte) error + type UpdatePlanRequest struct + Body string + Context string + PlanId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdatePlanRequest) Descriptor() ([]byte, []int) + func (*UpdatePlanRequest) ProtoMessage() + func (dst *UpdatePlanRequest) XXX_Merge(src proto.Message) + func (m *UpdatePlanRequest) GetBody() string + func (m *UpdatePlanRequest) GetContext() string + func (m *UpdatePlanRequest) GetPlanId() string + func (m *UpdatePlanRequest) Reset() + func (m *UpdatePlanRequest) String() string + func (m *UpdatePlanRequest) XXX_DiscardUnknown() + func (m *UpdatePlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdatePlanRequest) XXX_Size() int + func (m *UpdatePlanRequest) XXX_Unmarshal(b []byte) error + type UpdatePlanResponse struct + Err string + Plan *Plan + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdatePlanResponse) Descriptor() ([]byte, []int) + func (*UpdatePlanResponse) ProtoMessage() + func (dst *UpdatePlanResponse) XXX_Merge(src proto.Message) + func (m *UpdatePlanResponse) GetErr() string + func (m *UpdatePlanResponse) GetPlan() *Plan + func (m *UpdatePlanResponse) Reset() + func (m *UpdatePlanResponse) String() string + func (m *UpdatePlanResponse) XXX_DiscardUnknown() + func (m *UpdatePlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdatePlanResponse) XXX_Size() int + func (m *UpdatePlanResponse) XXX_Unmarshal(b []byte) error + type UpdatePolicyRequest struct + Body string + Context string + PolicyId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdatePolicyRequest) Descriptor() ([]byte, []int) + func (*UpdatePolicyRequest) ProtoMessage() + func (dst *UpdatePolicyRequest) XXX_Merge(src proto.Message) + func (m *UpdatePolicyRequest) GetBody() string + func (m *UpdatePolicyRequest) GetContext() string + func (m *UpdatePolicyRequest) GetPolicyId() string + func (m *UpdatePolicyRequest) Reset() + func (m *UpdatePolicyRequest) String() string + func (m *UpdatePolicyRequest) XXX_DiscardUnknown() + func (m *UpdatePolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdatePolicyRequest) XXX_Size() int + func (m *UpdatePolicyRequest) XXX_Unmarshal(b []byte) error + type UpdatePolicyResponse struct + Err string + Policy *Policy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdatePolicyResponse) Descriptor() ([]byte, []int) + func (*UpdatePolicyResponse) ProtoMessage() + func (dst *UpdatePolicyResponse) XXX_Merge(src proto.Message) + func (m *UpdatePolicyResponse) GetErr() string + func (m *UpdatePolicyResponse) GetPolicy() *Policy + func (m *UpdatePolicyResponse) Reset() + func (m *UpdatePolicyResponse) String() string + func (m *UpdatePolicyResponse) XXX_DiscardUnknown() + func (m *UpdatePolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdatePolicyResponse) XXX_Size() int + func (m *UpdatePolicyResponse) XXX_Unmarshal(b []byte) error
Go to main page