data_lifecycle

package
v0.0.0-...-4b711b1 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Overview

Package data_lifecycle is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_external_data_lifecycle_data_lifecycle_proto protoreflect.FileDescriptor

Functions

func RegisterDataLifecycleHandler 

func RegisterDataLifecycleHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterDataLifecycleHandler registers the http handlers for service DataLifecycle to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDataLifecycleHandlerClient 

func RegisterDataLifecycleHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DataLifecycleClient) error

RegisterDataLifecycleHandlerClient registers the http handlers for service DataLifecycle to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DataLifecycleClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DataLifecycleClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DataLifecycleClient" to call the correct interceptors.

func RegisterDataLifecycleHandlerFromEndpoint 

func RegisterDataLifecycleHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDataLifecycleHandlerFromEndpoint is same as RegisterDataLifecycleHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDataLifecycleHandlerServer 

func RegisterDataLifecycleHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DataLifecycleServer) error

RegisterDataLifecycleHandlerServer registers the http handlers for service DataLifecycle to "mux". UnaryRPC :call DataLifecycleServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterDataLifecycleServer 

func RegisterDataLifecycleServer(s *grpc.Server, srv DataLifecycleServer)

Types

type DataLifecycleClient 

type DataLifecycleClient interface {
	// GetStatus returns the aggregate status across all data lifecycle jobs
	GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)
	// SetConfig provides a singular endpoint for configuring all data lifecycle jobs
	SetConfig(ctx context.Context, in *SetConfigRequest, opts ...grpc.CallOption) (*SetConfigResponse, error)
	// Run runs all data lifecycle actions across all data lifecycle jobs
	Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
	// GetInfraStatus returns the infra job scheduler status
	GetInfraStatus(ctx context.Context, in *GetInfraStatusRequest, opts ...grpc.CallOption) (*GetInfraStatusResponse, error)
	// RunInfra runs the infra data lifecycle jobs
	RunInfra(ctx context.Context, in *RunInfraRequest, opts ...grpc.CallOption) (*RunInfraResponse, error)
	// SetInfraConfig configures the infra data lifecycle scheduler and jobs
	SetInfraConfig(ctx context.Context, in *SetInfraConfigRequest, opts ...grpc.CallOption) (*SetInfraConfigResponse, error)
	// Services
	GetServicesStatus(ctx context.Context, in *GetServicesStatusRequest, opts ...grpc.CallOption) (*GetServicesStatusResponse, error)
	RunServices(ctx context.Context, in *RunServicesRequest, opts ...grpc.CallOption) (*RunServicesResponse, error)
	SetServicesConfig(ctx context.Context, in *SetServicesConfigRequest, opts ...grpc.CallOption) (*SetServicesConfigResponse, error)
	// GetEventFeedStatus returns the event feed job scheduler status
	GetEventFeedStatus(ctx context.Context, in *GetEventFeedStatusRequest, opts ...grpc.CallOption) (*GetEventFeedStatusResponse, error)
	// RunEventFeed runs the event feed data lifecycle jobs
	RunEventFeed(ctx context.Context, in *RunEventFeedRequest, opts ...grpc.CallOption) (*RunEventFeedResponse, error)
	// SetEventFeedConfig configures the event feed data lifecycle scheduler and jobs
	SetEventFeedConfig(ctx context.Context, in *SetEventFeedConfigRequest, opts ...grpc.CallOption) (*SetEventFeedConfigResponse, error)
	// GetComplianceStatus returns the compliance job scheduler status
	GetComplianceStatus(ctx context.Context, in *GetComplianceStatusRequest, opts ...grpc.CallOption) (*GetComplianceStatusResponse, error)
	// RunCompliance runs the compliance data lifecycle jobs
	RunCompliance(ctx context.Context, in *RunComplianceRequest, opts ...grpc.CallOption) (*RunComplianceResponse, error)
	// SetComplianceConfig configures the compliance data lifecycle scheduler and jobs
	SetComplianceConfig(ctx context.Context, in *SetComplianceConfigRequest, opts ...grpc.CallOption) (*SetComplianceConfigResponse, error)
}

DataLifecycleClient is the client API for DataLifecycle service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDataLifecycleClient 

func NewDataLifecycleClient(cc grpc.ClientConnInterface) DataLifecycleClient

type DataLifecycleServer 

type DataLifecycleServer interface {
	// GetStatus returns the aggregate status across all data lifecycle jobs
	GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
	// SetConfig provides a singular endpoint for configuring all data lifecycle jobs
	SetConfig(context.Context, *SetConfigRequest) (*SetConfigResponse, error)
	// Run runs all data lifecycle actions across all data lifecycle jobs
	Run(context.Context, *RunRequest) (*RunResponse, error)
	// GetInfraStatus returns the infra job scheduler status
	GetInfraStatus(context.Context, *GetInfraStatusRequest) (*GetInfraStatusResponse, error)
	// RunInfra runs the infra data lifecycle jobs
	RunInfra(context.Context, *RunInfraRequest) (*RunInfraResponse, error)
	// SetInfraConfig configures the infra data lifecycle scheduler and jobs
	SetInfraConfig(context.Context, *SetInfraConfigRequest) (*SetInfraConfigResponse, error)
	// Services
	GetServicesStatus(context.Context, *GetServicesStatusRequest) (*GetServicesStatusResponse, error)
	RunServices(context.Context, *RunServicesRequest) (*RunServicesResponse, error)
	SetServicesConfig(context.Context, *SetServicesConfigRequest) (*SetServicesConfigResponse, error)
	// GetEventFeedStatus returns the event feed job scheduler status
	GetEventFeedStatus(context.Context, *GetEventFeedStatusRequest) (*GetEventFeedStatusResponse, error)
	// RunEventFeed runs the event feed data lifecycle jobs
	RunEventFeed(context.Context, *RunEventFeedRequest) (*RunEventFeedResponse, error)
	// SetEventFeedConfig configures the event feed data lifecycle scheduler and jobs
	SetEventFeedConfig(context.Context, *SetEventFeedConfigRequest) (*SetEventFeedConfigResponse, error)
	// GetComplianceStatus returns the compliance job scheduler status
	GetComplianceStatus(context.Context, *GetComplianceStatusRequest) (*GetComplianceStatusResponse, error)
	// RunCompliance runs the compliance data lifecycle jobs
	RunCompliance(context.Context, *RunComplianceRequest) (*RunComplianceResponse, error)
	// SetComplianceConfig configures the compliance data lifecycle scheduler and jobs
	SetComplianceConfig(context.Context, *SetComplianceConfigRequest) (*SetComplianceConfigResponse, error)
}

DataLifecycleServer is the server API for DataLifecycle service.

type EsPolicy 

type EsPolicy struct {
	Name             string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Index            string `protobuf:"bytes,2,opt,name=index,proto3" json:"index,omitempty"`
	OlderThanDays    int32  `protobuf:"varint,3,opt,name=older_than_days,json=olderThanDays,proto3" json:"older_than_days,omitempty"`
	CustomPurgeField string `protobuf:"bytes,4,opt,name=custom_purge_field,json=customPurgeField,proto3" json:"custom_purge_field,omitempty"`
	Disabled         bool   `protobuf:"varint,5,opt,name=disabled,proto3" json:"disabled,omitempty"`
	// contains filtered or unexported fields
}

func (*EsPolicy) Descriptor deprecated 

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

Deprecated: Use EsPolicy.ProtoReflect.Descriptor instead.

func (*EsPolicy) GetCustomPurgeField 

func (x *EsPolicy) GetCustomPurgeField() string

func (*EsPolicy) GetDisabled 

func (x *EsPolicy) GetDisabled() bool

func (*EsPolicy) GetIndex 

func (x *EsPolicy) GetIndex() string

func (*EsPolicy) GetName 

func (x *EsPolicy) GetName() string

func (*EsPolicy) GetOlderThanDays 

func (x *EsPolicy) GetOlderThanDays() int32

func (*EsPolicy) ProtoMessage 

func (*EsPolicy) ProtoMessage()

func (*EsPolicy) ProtoReflect 

func (x *EsPolicy) ProtoReflect() protoreflect.Message

func (*EsPolicy) Reset 

func (x *EsPolicy) Reset()

func (*EsPolicy) String 

func (x *EsPolicy) String() string

type EsPolicyUpdate 

type EsPolicyUpdate struct {
	PolicyName    string `protobuf:"bytes,1,opt,name=policy_name,json=policyName,proto3" json:"policy_name,omitempty"`
	Disabled      bool   `protobuf:"varint,2,opt,name=disabled,proto3" json:"disabled,omitempty"`
	OlderThanDays int32  `protobuf:"varint,3,opt,name=older_than_days,json=olderThanDays,proto3" json:"older_than_days,omitempty"`
	// contains filtered or unexported fields
}

func (*EsPolicyUpdate) Descriptor deprecated 

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

Deprecated: Use EsPolicyUpdate.ProtoReflect.Descriptor instead.

func (*EsPolicyUpdate) GetDisabled 

func (x *EsPolicyUpdate) GetDisabled() bool

func (*EsPolicyUpdate) GetOlderThanDays 

func (x *EsPolicyUpdate) GetOlderThanDays() int32

func (*EsPolicyUpdate) GetPolicyName 

func (x *EsPolicyUpdate) GetPolicyName() string

func (*EsPolicyUpdate) ProtoMessage 

func (*EsPolicyUpdate) ProtoMessage()

func (*EsPolicyUpdate) ProtoReflect 

func (x *EsPolicyUpdate) ProtoReflect() protoreflect.Message

func (*EsPolicyUpdate) Reset 

func (x *EsPolicyUpdate) Reset()

func (*EsPolicyUpdate) String 

func (x *EsPolicyUpdate) String() string

type GetComplianceStatusRequest 

type GetComplianceStatusRequest struct {
	// contains filtered or unexported fields
}

func (*GetComplianceStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetComplianceStatusRequest.ProtoReflect.Descriptor instead.

func (*GetComplianceStatusRequest) ProtoMessage 

func (*GetComplianceStatusRequest) ProtoMessage()

func (*GetComplianceStatusRequest) ProtoReflect 

func (x *GetComplianceStatusRequest) ProtoReflect() protoreflect.Message

func (*GetComplianceStatusRequest) Reset 

func (x *GetComplianceStatusRequest) Reset()

func (*GetComplianceStatusRequest) String 

func (x *GetComplianceStatusRequest) String() string

type GetComplianceStatusResponse 

type GetComplianceStatusResponse struct {
	Jobs []*JobStatus `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetComplianceStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetComplianceStatusResponse.ProtoReflect.Descriptor instead.

func (*GetComplianceStatusResponse) GetJobs 

func (x *GetComplianceStatusResponse) GetJobs() []*JobStatus

func (*GetComplianceStatusResponse) ProtoMessage 

func (*GetComplianceStatusResponse) ProtoMessage()

func (*GetComplianceStatusResponse) ProtoReflect 

func (x *GetComplianceStatusResponse) ProtoReflect() protoreflect.Message

func (*GetComplianceStatusResponse) Reset 

func (x *GetComplianceStatusResponse) Reset()

func (*GetComplianceStatusResponse) String 

func (x *GetComplianceStatusResponse) String() string

type GetEventFeedStatusRequest 

type GetEventFeedStatusRequest struct {
	// contains filtered or unexported fields
}

func (*GetEventFeedStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetEventFeedStatusRequest.ProtoReflect.Descriptor instead.

func (*GetEventFeedStatusRequest) ProtoMessage 

func (*GetEventFeedStatusRequest) ProtoMessage()

func (*GetEventFeedStatusRequest) ProtoReflect 

func (x *GetEventFeedStatusRequest) ProtoReflect() protoreflect.Message

func (*GetEventFeedStatusRequest) Reset 

func (x *GetEventFeedStatusRequest) Reset()

func (*GetEventFeedStatusRequest) String 

func (x *GetEventFeedStatusRequest) String() string

type GetEventFeedStatusResponse 

type GetEventFeedStatusResponse struct {
	Jobs []*JobStatus `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventFeedStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetEventFeedStatusResponse.ProtoReflect.Descriptor instead.

func (*GetEventFeedStatusResponse) GetJobs 

func (x *GetEventFeedStatusResponse) GetJobs() []*JobStatus

func (*GetEventFeedStatusResponse) ProtoMessage 

func (*GetEventFeedStatusResponse) ProtoMessage()

func (*GetEventFeedStatusResponse) ProtoReflect 

func (x *GetEventFeedStatusResponse) ProtoReflect() protoreflect.Message

func (*GetEventFeedStatusResponse) Reset 

func (x *GetEventFeedStatusResponse) Reset()

func (*GetEventFeedStatusResponse) String 

func (x *GetEventFeedStatusResponse) String() string

type GetInfraStatusRequest 

type GetInfraStatusRequest struct {
	// contains filtered or unexported fields
}

func (*GetInfraStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetInfraStatusRequest.ProtoReflect.Descriptor instead.

func (*GetInfraStatusRequest) ProtoMessage 

func (*GetInfraStatusRequest) ProtoMessage()

func (*GetInfraStatusRequest) ProtoReflect 

func (x *GetInfraStatusRequest) ProtoReflect() protoreflect.Message

func (*GetInfraStatusRequest) Reset 

func (x *GetInfraStatusRequest) Reset()

func (*GetInfraStatusRequest) String 

func (x *GetInfraStatusRequest) String() string

type GetInfraStatusResponse 

type GetInfraStatusResponse struct {
	Jobs []*JobStatus `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInfraStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetInfraStatusResponse.ProtoReflect.Descriptor instead.

func (*GetInfraStatusResponse) GetJobs 

func (x *GetInfraStatusResponse) GetJobs() []*JobStatus

func (*GetInfraStatusResponse) ProtoMessage 

func (*GetInfraStatusResponse) ProtoMessage()

func (*GetInfraStatusResponse) ProtoReflect 

func (x *GetInfraStatusResponse) ProtoReflect() protoreflect.Message

func (*GetInfraStatusResponse) Reset 

func (x *GetInfraStatusResponse) Reset()

func (*GetInfraStatusResponse) String 

func (x *GetInfraStatusResponse) String() string

type GetServicesStatusRequest 

type GetServicesStatusRequest struct {
	// contains filtered or unexported fields
}

func (*GetServicesStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetServicesStatusRequest.ProtoReflect.Descriptor instead.

func (*GetServicesStatusRequest) ProtoMessage 

func (*GetServicesStatusRequest) ProtoMessage()

func (*GetServicesStatusRequest) ProtoReflect 

func (x *GetServicesStatusRequest) ProtoReflect() protoreflect.Message

func (*GetServicesStatusRequest) Reset 

func (x *GetServicesStatusRequest) Reset()

func (*GetServicesStatusRequest) String 

func (x *GetServicesStatusRequest) String() string

type GetServicesStatusResponse 

type GetServicesStatusResponse struct {
	Jobs []*JobStatus `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServicesStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetServicesStatusResponse.ProtoReflect.Descriptor instead.

func (*GetServicesStatusResponse) GetJobs 

func (x *GetServicesStatusResponse) GetJobs() []*JobStatus

func (*GetServicesStatusResponse) ProtoMessage 

func (*GetServicesStatusResponse) ProtoMessage()

func (*GetServicesStatusResponse) ProtoReflect 

func (x *GetServicesStatusResponse) ProtoReflect() protoreflect.Message

func (*GetServicesStatusResponse) Reset 

func (x *GetServicesStatusResponse) Reset()

func (*GetServicesStatusResponse) String 

func (x *GetServicesStatusResponse) String() string

type GetStatusRequest 

type GetStatusRequest struct {
	// contains filtered or unexported fields
}

func (*GetStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStatusRequest) ProtoMessage 

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) ProtoReflect 

func (x *GetStatusRequest) ProtoReflect() protoreflect.Message

func (*GetStatusRequest) Reset 

func (x *GetStatusRequest) Reset()

func (*GetStatusRequest) String 

func (x *GetStatusRequest) String() string

type GetStatusResponse 

type GetStatusResponse struct {
	Infra      *GetInfraStatusResponse      `protobuf:"bytes,1,opt,name=infra,proto3" json:"infra,omitempty"`
	Compliance *GetComplianceStatusResponse `protobuf:"bytes,2,opt,name=compliance,proto3" json:"compliance,omitempty"`
	EventFeed  *GetEventFeedStatusResponse  `protobuf:"bytes,3,opt,name=event_feed,json=eventFeed,proto3" json:"event_feed,omitempty"`
	Services   *GetServicesStatusResponse   `protobuf:"bytes,4,opt,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetStatusResponse.ProtoReflect.Descriptor instead.

func (*GetStatusResponse) GetCompliance 

func (x *GetStatusResponse) GetCompliance() *GetComplianceStatusResponse

func (*GetStatusResponse) GetEventFeed 

func (x *GetStatusResponse) GetEventFeed() *GetEventFeedStatusResponse

func (*GetStatusResponse) GetInfra 

func (x *GetStatusResponse) GetInfra() *GetInfraStatusResponse

func (*GetStatusResponse) GetServices 

func (x *GetStatusResponse) GetServices() *GetServicesStatusResponse

func (*GetStatusResponse) ProtoMessage 

func (*GetStatusResponse) ProtoMessage()

func (*GetStatusResponse) ProtoReflect 

func (x *GetStatusResponse) ProtoReflect() protoreflect.Message

func (*GetStatusResponse) Reset 

func (x *GetStatusResponse) Reset()

func (*GetStatusResponse) String 

func (x *GetStatusResponse) String() string

type JobSettings 

type JobSettings struct {
	Name          string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Disabled      bool               `protobuf:"varint,2,opt,name=disabled,proto3" json:"disabled,omitempty"`
	Recurrence    string             `protobuf:"bytes,3,opt,name=recurrence,proto3" json:"recurrence,omitempty"`
	Threshold     string             `protobuf:"bytes,4,opt,name=threshold,proto3" json:"threshold,omitempty"`
	PurgePolicies *PurgePolicyUpdate `protobuf:"bytes,5,opt,name=purge_policies,json=purgePolicies,proto3" json:"purge_policies,omitempty"`
	// contains filtered or unexported fields
}

JobSettings are a job configuration setting update

func (*JobSettings) Descriptor deprecated 

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

Deprecated: Use JobSettings.ProtoReflect.Descriptor instead.

func (*JobSettings) GetDisabled 

func (x *JobSettings) GetDisabled() bool

func (*JobSettings) GetName 

func (x *JobSettings) GetName() string

func (*JobSettings) GetPurgePolicies 

func (x *JobSettings) GetPurgePolicies() *PurgePolicyUpdate

func (*JobSettings) GetRecurrence 

func (x *JobSettings) GetRecurrence() string

func (*JobSettings) GetThreshold 

func (x *JobSettings) GetThreshold() string

func (*JobSettings) ProtoMessage 

func (*JobSettings) ProtoMessage()

func (*JobSettings) ProtoReflect 

func (x *JobSettings) ProtoReflect() protoreflect.Message

func (*JobSettings) Reset 

func (x *JobSettings) Reset()

func (*JobSettings) String 

func (x *JobSettings) String() string

type JobStatus 

type JobStatus struct {
	Name           string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Disabled       bool                   `protobuf:"varint,2,opt,name=disabled,proto3" json:"disabled,omitempty"`
	Recurrence     string                 `protobuf:"bytes,3,opt,name=recurrence,proto3" json:"recurrence,omitempty"`
	Threshold      string                 `protobuf:"bytes,4,opt,name=threshold,proto3" json:"threshold,omitempty"`
	PurgePolicies  *PurgePolicies         `protobuf:"bytes,5,opt,name=purge_policies,json=purgePolicies,proto3" json:"purge_policies,omitempty"`
	LastElapsed    *durationpb.Duration   `protobuf:"bytes,6,opt,name=last_elapsed,json=lastElapsed,proto3" json:"last_elapsed,omitempty"`
	NextDueAt      *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=next_due_at,json=nextDueAt,proto3" json:"next_due_at,omitempty"`
	LastEnqueuedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=last_enqueued_at,json=lastEnqueuedAt,proto3" json:"last_enqueued_at,omitempty"`
	LastStartedAt  *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=last_started_at,json=lastStartedAt,proto3" json:"last_started_at,omitempty"`
	LastEndedAt    *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=last_ended_at,json=lastEndedAt,proto3" json:"last_ended_at,omitempty"`
	// contains filtered or unexported fields
}

JobStatus presents the current configuration of job, when it will be executed, and details about it's most recent execution.

func (*JobStatus) Descriptor deprecated 

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

Deprecated: Use JobStatus.ProtoReflect.Descriptor instead.

func (*JobStatus) GetDisabled 

func (x *JobStatus) GetDisabled() bool

func (*JobStatus) GetLastElapsed 

func (x *JobStatus) GetLastElapsed() *durationpb.Duration

func (*JobStatus) GetLastEndedAt 

func (x *JobStatus) GetLastEndedAt() *timestamppb.Timestamp

func (*JobStatus) GetLastEnqueuedAt 

func (x *JobStatus) GetLastEnqueuedAt() *timestamppb.Timestamp

func (*JobStatus) GetLastStartedAt 

func (x *JobStatus) GetLastStartedAt() *timestamppb.Timestamp

func (*JobStatus) GetName 

func (x *JobStatus) GetName() string

func (*JobStatus) GetNextDueAt 

func (x *JobStatus) GetNextDueAt() *timestamppb.Timestamp

func (*JobStatus) GetPurgePolicies 

func (x *JobStatus) GetPurgePolicies() *PurgePolicies

func (*JobStatus) GetRecurrence 

func (x *JobStatus) GetRecurrence() string

func (*JobStatus) GetThreshold 

func (x *JobStatus) GetThreshold() string

func (*JobStatus) ProtoMessage 

func (*JobStatus) ProtoMessage()

func (*JobStatus) ProtoReflect 

func (x *JobStatus) ProtoReflect() protoreflect.Message

func (*JobStatus) Reset 

func (x *JobStatus) Reset()

func (*JobStatus) String 

func (x *JobStatus) String() string

type PgPolicy 

type PgPolicy struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Disabled bool   `protobuf:"varint,2,opt,name=disabled,proto3" json:"disabled,omitempty"`
	// contains filtered or unexported fields
}

func (*PgPolicy) Descriptor deprecated 

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

Deprecated: Use PgPolicy.ProtoReflect.Descriptor instead.

func (*PgPolicy) GetDisabled 

func (x *PgPolicy) GetDisabled() bool

func (*PgPolicy) GetName 

func (x *PgPolicy) GetName() string

func (*PgPolicy) ProtoMessage 

func (*PgPolicy) ProtoMessage()

func (*PgPolicy) ProtoReflect 

func (x *PgPolicy) ProtoReflect() protoreflect.Message

func (*PgPolicy) Reset 

func (x *PgPolicy) Reset()

func (*PgPolicy) String 

func (x *PgPolicy) String() string

type PgPolicyUpdate 

type PgPolicyUpdate struct {
	PolicyName string `protobuf:"bytes,1,opt,name=policy_name,json=policyName,proto3" json:"policy_name,omitempty"`
	Disabled   bool   `protobuf:"varint,2,opt,name=disabled,proto3" json:"disabled,omitempty"`
	// contains filtered or unexported fields
}

func (*PgPolicyUpdate) Descriptor deprecated 

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

Deprecated: Use PgPolicyUpdate.ProtoReflect.Descriptor instead.

func (*PgPolicyUpdate) GetDisabled 

func (x *PgPolicyUpdate) GetDisabled() bool

func (*PgPolicyUpdate) GetPolicyName 

func (x *PgPolicyUpdate) GetPolicyName() string

func (*PgPolicyUpdate) ProtoMessage 

func (*PgPolicyUpdate) ProtoMessage()

func (*PgPolicyUpdate) ProtoReflect 

func (x *PgPolicyUpdate) ProtoReflect() protoreflect.Message

func (*PgPolicyUpdate) Reset 

func (x *PgPolicyUpdate) Reset()

func (*PgPolicyUpdate) String 

func (x *PgPolicyUpdate) String() string

type PurgePolicies 

type PurgePolicies struct {
	Elasticsearch []*EsPolicy `protobuf:"bytes,1,rep,name=elasticsearch,proto3" json:"elasticsearch,omitempty"`
	Postgres      []*PgPolicy `protobuf:"bytes,2,rep,name=postgres,proto3" json:"postgres,omitempty"`
	// contains filtered or unexported fields
}

PurgePolicies are data lifecycle purge policies

func (*PurgePolicies) Descriptor deprecated 

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

Deprecated: Use PurgePolicies.ProtoReflect.Descriptor instead.

func (*PurgePolicies) GetElasticsearch 

func (x *PurgePolicies) GetElasticsearch() []*EsPolicy

func (*PurgePolicies) GetPostgres 

func (x *PurgePolicies) GetPostgres() []*PgPolicy

func (*PurgePolicies) ProtoMessage 

func (*PurgePolicies) ProtoMessage()

func (*PurgePolicies) ProtoReflect 

func (x *PurgePolicies) ProtoReflect() protoreflect.Message

func (*PurgePolicies) Reset 

func (x *PurgePolicies) Reset()

func (*PurgePolicies) String 

func (x *PurgePolicies) String() string

type PurgePolicyUpdate 

type PurgePolicyUpdate struct {
	Elasticsearch []*EsPolicyUpdate `protobuf:"bytes,1,rep,name=elasticsearch,proto3" json:"elasticsearch,omitempty"`
	Postgres      []*PgPolicyUpdate `protobuf:"bytes,2,rep,name=postgres,proto3" json:"postgres,omitempty"`
	// contains filtered or unexported fields
}

PurgePolicyUpdate is purge policy configuration update

func (*PurgePolicyUpdate) Descriptor deprecated 

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

Deprecated: Use PurgePolicyUpdate.ProtoReflect.Descriptor instead.

func (*PurgePolicyUpdate) GetElasticsearch 

func (x *PurgePolicyUpdate) GetElasticsearch() []*EsPolicyUpdate

func (*PurgePolicyUpdate) GetPostgres 

func (x *PurgePolicyUpdate) GetPostgres() []*PgPolicyUpdate

func (*PurgePolicyUpdate) ProtoMessage 

func (*PurgePolicyUpdate) ProtoMessage()

func (*PurgePolicyUpdate) ProtoReflect 

func (x *PurgePolicyUpdate) ProtoReflect() protoreflect.Message

func (*PurgePolicyUpdate) Reset 

func (x *PurgePolicyUpdate) Reset()

func (*PurgePolicyUpdate) String 

func (x *PurgePolicyUpdate) String() string

type RunComplianceRequest 

type RunComplianceRequest struct {
	// contains filtered or unexported fields
}

func (*RunComplianceRequest) Descriptor deprecated 

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

Deprecated: Use RunComplianceRequest.ProtoReflect.Descriptor instead.

func (*RunComplianceRequest) ProtoMessage 

func (*RunComplianceRequest) ProtoMessage()

func (*RunComplianceRequest) ProtoReflect 

func (x *RunComplianceRequest) ProtoReflect() protoreflect.Message

func (*RunComplianceRequest) Reset 

func (x *RunComplianceRequest) Reset()

func (*RunComplianceRequest) String 

func (x *RunComplianceRequest) String() string

type RunComplianceResponse 

type RunComplianceResponse struct {
	// contains filtered or unexported fields
}

func (*RunComplianceResponse) Descriptor deprecated 

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

Deprecated: Use RunComplianceResponse.ProtoReflect.Descriptor instead.

func (*RunComplianceResponse) ProtoMessage 

func (*RunComplianceResponse) ProtoMessage()

func (*RunComplianceResponse) ProtoReflect 

func (x *RunComplianceResponse) ProtoReflect() protoreflect.Message

func (*RunComplianceResponse) Reset 

func (x *RunComplianceResponse) Reset()

func (*RunComplianceResponse) String 

func (x *RunComplianceResponse) String() string

type RunEventFeedRequest 

type RunEventFeedRequest struct {
	// contains filtered or unexported fields
}

func (*RunEventFeedRequest) Descriptor deprecated 

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

Deprecated: Use RunEventFeedRequest.ProtoReflect.Descriptor instead.

func (*RunEventFeedRequest) ProtoMessage 

func (*RunEventFeedRequest) ProtoMessage()

func (*RunEventFeedRequest) ProtoReflect 

func (x *RunEventFeedRequest) ProtoReflect() protoreflect.Message

func (*RunEventFeedRequest) Reset 

func (x *RunEventFeedRequest) Reset()

func (*RunEventFeedRequest) String 

func (x *RunEventFeedRequest) String() string

type RunEventFeedResponse 

type RunEventFeedResponse struct {
	// contains filtered or unexported fields
}

func (*RunEventFeedResponse) Descriptor deprecated 

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

Deprecated: Use RunEventFeedResponse.ProtoReflect.Descriptor instead.

func (*RunEventFeedResponse) ProtoMessage 

func (*RunEventFeedResponse) ProtoMessage()

func (*RunEventFeedResponse) ProtoReflect 

func (x *RunEventFeedResponse) ProtoReflect() protoreflect.Message

func (*RunEventFeedResponse) Reset 

func (x *RunEventFeedResponse) Reset()

func (*RunEventFeedResponse) String 

func (x *RunEventFeedResponse) String() string

type RunInfraRequest 

type RunInfraRequest struct {
	// contains filtered or unexported fields
}

func (*RunInfraRequest) Descriptor deprecated 

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

Deprecated: Use RunInfraRequest.ProtoReflect.Descriptor instead.

func (*RunInfraRequest) ProtoMessage 

func (*RunInfraRequest) ProtoMessage()

func (*RunInfraRequest) ProtoReflect 

func (x *RunInfraRequest) ProtoReflect() protoreflect.Message

func (*RunInfraRequest) Reset 

func (x *RunInfraRequest) Reset()

func (*RunInfraRequest) String 

func (x *RunInfraRequest) String() string

type RunInfraResponse 

type RunInfraResponse struct {
	// contains filtered or unexported fields
}

func (*RunInfraResponse) Descriptor deprecated 

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

Deprecated: Use RunInfraResponse.ProtoReflect.Descriptor instead.

func (*RunInfraResponse) ProtoMessage 

func (*RunInfraResponse) ProtoMessage()

func (*RunInfraResponse) ProtoReflect 

func (x *RunInfraResponse) ProtoReflect() protoreflect.Message

func (*RunInfraResponse) Reset 

func (x *RunInfraResponse) Reset()

func (*RunInfraResponse) String 

func (x *RunInfraResponse) String() string

type RunRequest 

type RunRequest struct {
	// contains filtered or unexported fields
}

func (*RunRequest) Descriptor deprecated 

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

Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.

func (*RunRequest) ProtoMessage 

func (*RunRequest) ProtoMessage()

func (*RunRequest) ProtoReflect 

func (x *RunRequest) ProtoReflect() protoreflect.Message

func (*RunRequest) Reset 

func (x *RunRequest) Reset()

func (*RunRequest) String 

func (x *RunRequest) String() string

type RunResponse 

type RunResponse struct {
	// contains filtered or unexported fields
}

func (*RunResponse) Descriptor deprecated 

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

Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.

func (*RunResponse) ProtoMessage 

func (*RunResponse) ProtoMessage()

func (*RunResponse) ProtoReflect 

func (x *RunResponse) ProtoReflect() protoreflect.Message

func (*RunResponse) Reset 

func (x *RunResponse) Reset()

func (*RunResponse) String 

func (x *RunResponse) String() string

type RunServicesRequest 

type RunServicesRequest struct {
	// contains filtered or unexported fields
}

func (*RunServicesRequest) Descriptor deprecated 

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

Deprecated: Use RunServicesRequest.ProtoReflect.Descriptor instead.

func (*RunServicesRequest) ProtoMessage 

func (*RunServicesRequest) ProtoMessage()

func (*RunServicesRequest) ProtoReflect 

func (x *RunServicesRequest) ProtoReflect() protoreflect.Message

func (*RunServicesRequest) Reset 

func (x *RunServicesRequest) Reset()

func (*RunServicesRequest) String 

func (x *RunServicesRequest) String() string

type RunServicesResponse 

type RunServicesResponse struct {
	// contains filtered or unexported fields
}

func (*RunServicesResponse) Descriptor deprecated 

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

Deprecated: Use RunServicesResponse.ProtoReflect.Descriptor instead.

func (*RunServicesResponse) ProtoMessage 

func (*RunServicesResponse) ProtoMessage()

func (*RunServicesResponse) ProtoReflect 

func (x *RunServicesResponse) ProtoReflect() protoreflect.Message

func (*RunServicesResponse) Reset 

func (x *RunServicesResponse) Reset()

func (*RunServicesResponse) String 

func (x *RunServicesResponse) String() string

type SetComplianceConfigRequest 

type SetComplianceConfigRequest struct {
	JobSettings []*JobSettings `protobuf:"bytes,1,rep,name=job_settings,json=jobSettings,proto3" json:"job_settings,omitempty"`
	// contains filtered or unexported fields
}

func (*SetComplianceConfigRequest) Descriptor deprecated 

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

Deprecated: Use SetComplianceConfigRequest.ProtoReflect.Descriptor instead.

func (*SetComplianceConfigRequest) GetJobSettings 

func (x *SetComplianceConfigRequest) GetJobSettings() []*JobSettings

func (*SetComplianceConfigRequest) ProtoMessage 

func (*SetComplianceConfigRequest) ProtoMessage()

func (*SetComplianceConfigRequest) ProtoReflect 

func (x *SetComplianceConfigRequest) ProtoReflect() protoreflect.Message

func (*SetComplianceConfigRequest) Reset 

func (x *SetComplianceConfigRequest) Reset()

func (*SetComplianceConfigRequest) String 

func (x *SetComplianceConfigRequest) String() string

type SetComplianceConfigResponse 

type SetComplianceConfigResponse struct {
	// contains filtered or unexported fields
}

func (*SetComplianceConfigResponse) Descriptor deprecated 

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

Deprecated: Use SetComplianceConfigResponse.ProtoReflect.Descriptor instead.

func (*SetComplianceConfigResponse) ProtoMessage 

func (*SetComplianceConfigResponse) ProtoMessage()

func (*SetComplianceConfigResponse) ProtoReflect 

func (x *SetComplianceConfigResponse) ProtoReflect() protoreflect.Message

func (*SetComplianceConfigResponse) Reset 

func (x *SetComplianceConfigResponse) Reset()

func (*SetComplianceConfigResponse) String 

func (x *SetComplianceConfigResponse) String() string

type SetConfigRequest 

type SetConfigRequest struct {
	Infra      *SetInfraConfigRequest      `protobuf:"bytes,1,opt,name=infra,proto3" json:"infra,omitempty"`
	Compliance *SetComplianceConfigRequest `protobuf:"bytes,2,opt,name=compliance,proto3" json:"compliance,omitempty"`
	EventFeed  *SetEventFeedConfigRequest  `protobuf:"bytes,3,opt,name=event_feed,json=eventFeed,proto3" json:"event_feed,omitempty"`
	Services   *SetServicesConfigRequest   `protobuf:"bytes,4,opt,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*SetConfigRequest) Descriptor deprecated 

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

Deprecated: Use SetConfigRequest.ProtoReflect.Descriptor instead.

func (*SetConfigRequest) GetCompliance 

func (x *SetConfigRequest) GetCompliance() *SetComplianceConfigRequest

func (*SetConfigRequest) GetEventFeed 

func (x *SetConfigRequest) GetEventFeed() *SetEventFeedConfigRequest

func (*SetConfigRequest) GetInfra 

func (x *SetConfigRequest) GetInfra() *SetInfraConfigRequest

func (*SetConfigRequest) GetServices 

func (x *SetConfigRequest) GetServices() *SetServicesConfigRequest

func (*SetConfigRequest) ProtoMessage 

func (*SetConfigRequest) ProtoMessage()

func (*SetConfigRequest) ProtoReflect 

func (x *SetConfigRequest) ProtoReflect() protoreflect.Message

func (*SetConfigRequest) Reset 

func (x *SetConfigRequest) Reset()

func (*SetConfigRequest) String 

func (x *SetConfigRequest) String() string

type SetConfigResponse 

type SetConfigResponse struct {
	// contains filtered or unexported fields
}

func (*SetConfigResponse) Descriptor deprecated 

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

Deprecated: Use SetConfigResponse.ProtoReflect.Descriptor instead.

func (*SetConfigResponse) ProtoMessage 

func (*SetConfigResponse) ProtoMessage()

func (*SetConfigResponse) ProtoReflect 

func (x *SetConfigResponse) ProtoReflect() protoreflect.Message

func (*SetConfigResponse) Reset 

func (x *SetConfigResponse) Reset()

func (*SetConfigResponse) String 

func (x *SetConfigResponse) String() string

type SetEventFeedConfigRequest 

type SetEventFeedConfigRequest struct {
	JobSettings []*JobSettings `protobuf:"bytes,1,rep,name=job_settings,json=jobSettings,proto3" json:"job_settings,omitempty"`
	// contains filtered or unexported fields
}

func (*SetEventFeedConfigRequest) Descriptor deprecated 

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

Deprecated: Use SetEventFeedConfigRequest.ProtoReflect.Descriptor instead.

func (*SetEventFeedConfigRequest) GetJobSettings 

func (x *SetEventFeedConfigRequest) GetJobSettings() []*JobSettings

func (*SetEventFeedConfigRequest) ProtoMessage 

func (*SetEventFeedConfigRequest) ProtoMessage()

func (*SetEventFeedConfigRequest) ProtoReflect 

func (x *SetEventFeedConfigRequest) ProtoReflect() protoreflect.Message

func (*SetEventFeedConfigRequest) Reset 

func (x *SetEventFeedConfigRequest) Reset()

func (*SetEventFeedConfigRequest) String 

func (x *SetEventFeedConfigRequest) String() string

type SetEventFeedConfigResponse 

type SetEventFeedConfigResponse struct {
	// contains filtered or unexported fields
}

func (*SetEventFeedConfigResponse) Descriptor deprecated 

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

Deprecated: Use SetEventFeedConfigResponse.ProtoReflect.Descriptor instead.

func (*SetEventFeedConfigResponse) ProtoMessage 

func (*SetEventFeedConfigResponse) ProtoMessage()

func (*SetEventFeedConfigResponse) ProtoReflect 

func (x *SetEventFeedConfigResponse) ProtoReflect() protoreflect.Message

func (*SetEventFeedConfigResponse) Reset 

func (x *SetEventFeedConfigResponse) Reset()

func (*SetEventFeedConfigResponse) String 

func (x *SetEventFeedConfigResponse) String() string

type SetInfraConfigRequest 

type SetInfraConfigRequest struct {
	JobSettings []*JobSettings `protobuf:"bytes,1,rep,name=job_settings,json=jobSettings,proto3" json:"job_settings,omitempty"`
	// contains filtered or unexported fields
}

func (*SetInfraConfigRequest) Descriptor deprecated 

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

Deprecated: Use SetInfraConfigRequest.ProtoReflect.Descriptor instead.

func (*SetInfraConfigRequest) GetJobSettings 

func (x *SetInfraConfigRequest) GetJobSettings() []*JobSettings

func (*SetInfraConfigRequest) ProtoMessage 

func (*SetInfraConfigRequest) ProtoMessage()

func (*SetInfraConfigRequest) ProtoReflect 

func (x *SetInfraConfigRequest) ProtoReflect() protoreflect.Message

func (*SetInfraConfigRequest) Reset 

func (x *SetInfraConfigRequest) Reset()

func (*SetInfraConfigRequest) String 

func (x *SetInfraConfigRequest) String() string

type SetInfraConfigResponse 

type SetInfraConfigResponse struct {
	// contains filtered or unexported fields
}

func (*SetInfraConfigResponse) Descriptor deprecated 

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

Deprecated: Use SetInfraConfigResponse.ProtoReflect.Descriptor instead.

func (*SetInfraConfigResponse) ProtoMessage 

func (*SetInfraConfigResponse) ProtoMessage()

func (*SetInfraConfigResponse) ProtoReflect 

func (x *SetInfraConfigResponse) ProtoReflect() protoreflect.Message

func (*SetInfraConfigResponse) Reset 

func (x *SetInfraConfigResponse) Reset()

func (*SetInfraConfigResponse) String 

func (x *SetInfraConfigResponse) String() string

type SetServicesConfigRequest 

type SetServicesConfigRequest struct {
	JobSettings []*JobSettings `protobuf:"bytes,1,rep,name=job_settings,json=jobSettings,proto3" json:"job_settings,omitempty"`
	// contains filtered or unexported fields
}

func (*SetServicesConfigRequest) Descriptor deprecated 

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

Deprecated: Use SetServicesConfigRequest.ProtoReflect.Descriptor instead.

func (*SetServicesConfigRequest) GetJobSettings 

func (x *SetServicesConfigRequest) GetJobSettings() []*JobSettings

func (*SetServicesConfigRequest) ProtoMessage 

func (*SetServicesConfigRequest) ProtoMessage()

func (*SetServicesConfigRequest) ProtoReflect 

func (x *SetServicesConfigRequest) ProtoReflect() protoreflect.Message

func (*SetServicesConfigRequest) Reset 

func (x *SetServicesConfigRequest) Reset()

func (*SetServicesConfigRequest) String 

func (x *SetServicesConfigRequest) String() string

type SetServicesConfigResponse 

type SetServicesConfigResponse struct {
	// contains filtered or unexported fields
}

func (*SetServicesConfigResponse) Descriptor deprecated 

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

Deprecated: Use SetServicesConfigResponse.ProtoReflect.Descriptor instead.

func (*SetServicesConfigResponse) ProtoMessage 

func (*SetServicesConfigResponse) ProtoMessage()

func (*SetServicesConfigResponse) ProtoReflect 

func (x *SetServicesConfigResponse) ProtoReflect() protoreflect.Message

func (*SetServicesConfigResponse) Reset 

func (x *SetServicesConfigResponse) Reset()

func (*SetServicesConfigResponse) String 

func (x *SetServicesConfigResponse) String() string

type UnimplementedDataLifecycleServer 

type UnimplementedDataLifecycleServer struct {
}

UnimplementedDataLifecycleServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataLifecycleServer) GetComplianceStatus 

func (*UnimplementedDataLifecycleServer) GetComplianceStatus(context.Context, *GetComplianceStatusRequest) (*GetComplianceStatusResponse, error)

func (*UnimplementedDataLifecycleServer) GetEventFeedStatus 

func (*UnimplementedDataLifecycleServer) GetEventFeedStatus(context.Context, *GetEventFeedStatusRequest) (*GetEventFeedStatusResponse, error)

func (*UnimplementedDataLifecycleServer) GetInfraStatus 

func (*UnimplementedDataLifecycleServer) GetInfraStatus(context.Context, *GetInfraStatusRequest) (*GetInfraStatusResponse, error)

func (*UnimplementedDataLifecycleServer) GetServicesStatus 

func (*UnimplementedDataLifecycleServer) GetServicesStatus(context.Context, *GetServicesStatusRequest) (*GetServicesStatusResponse, error)

func (*UnimplementedDataLifecycleServer) GetStatus 

func (*UnimplementedDataLifecycleServer) GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)

func (*UnimplementedDataLifecycleServer) Run 

func (*UnimplementedDataLifecycleServer) Run(context.Context, *RunRequest) (*RunResponse, error)

func (*UnimplementedDataLifecycleServer) RunCompliance 

func (*UnimplementedDataLifecycleServer) RunCompliance(context.Context, *RunComplianceRequest) (*RunComplianceResponse, error)

func (*UnimplementedDataLifecycleServer) RunEventFeed 

func (*UnimplementedDataLifecycleServer) RunEventFeed(context.Context, *RunEventFeedRequest) (*RunEventFeedResponse, error)

func (*UnimplementedDataLifecycleServer) RunInfra 

func (*UnimplementedDataLifecycleServer) RunInfra(context.Context, *RunInfraRequest) (*RunInfraResponse, error)

func (*UnimplementedDataLifecycleServer) RunServices 

func (*UnimplementedDataLifecycleServer) RunServices(context.Context, *RunServicesRequest) (*RunServicesResponse, error)

func (*UnimplementedDataLifecycleServer) SetComplianceConfig 

func (*UnimplementedDataLifecycleServer) SetComplianceConfig(context.Context, *SetComplianceConfigRequest) (*SetComplianceConfigResponse, error)

func (*UnimplementedDataLifecycleServer) SetConfig 

func (*UnimplementedDataLifecycleServer) SetConfig(context.Context, *SetConfigRequest) (*SetConfigResponse, error)

func (*UnimplementedDataLifecycleServer) SetEventFeedConfig 

func (*UnimplementedDataLifecycleServer) SetEventFeedConfig(context.Context, *SetEventFeedConfigRequest) (*SetEventFeedConfigResponse, error)

func (*UnimplementedDataLifecycleServer) SetInfraConfig 

func (*UnimplementedDataLifecycleServer) SetInfraConfig(context.Context, *SetInfraConfigRequest) (*SetInfraConfigResponse, error)

func (*UnimplementedDataLifecycleServer) SetServicesConfig 

func (*UnimplementedDataLifecycleServer) SetServicesConfig(context.Context, *SetServicesConfigRequest) (*SetServicesConfigResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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