data_lifecycle

package
v0.0.0-...-565567d Latest Latest
Warning

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

 Go to latest Published: Nov 27, 2024 License: Apache-2.0 Imports: 10 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_interservice_data_lifecycle_purge_proto protoreflect.FileDescriptor

Functions

func RegisterPurgeServer 

func RegisterPurgeServer(s *grpc.Server, srv PurgeServer)

Types

type ConfigureRequest 

type ConfigureRequest struct {
	Enabled      bool          `` /* 126-byte string literal not displayed */
	Recurrence   string        `` /* 137-byte string literal not displayed */
	PolicyUpdate *PolicyUpdate `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigureRequest) Descriptor deprecated 

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

Deprecated: Use ConfigureRequest.ProtoReflect.Descriptor instead.

func (*ConfigureRequest) GetEnabled 

func (x *ConfigureRequest) GetEnabled() bool

func (*ConfigureRequest) GetPolicyUpdate 

func (x *ConfigureRequest) GetPolicyUpdate() *PolicyUpdate

func (*ConfigureRequest) GetRecurrence 

func (x *ConfigureRequest) GetRecurrence() string

func (*ConfigureRequest) ProtoMessage 

func (*ConfigureRequest) ProtoMessage()

func (*ConfigureRequest) ProtoReflect 

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

func (*ConfigureRequest) Reset 

func (x *ConfigureRequest) Reset()

func (*ConfigureRequest) String 

func (x *ConfigureRequest) String() string

type ConfigureResponse 

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

func (*ConfigureResponse) Descriptor deprecated 

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

Deprecated: Use ConfigureResponse.ProtoReflect.Descriptor instead.

func (*ConfigureResponse) ProtoMessage 

func (*ConfigureResponse) ProtoMessage()

func (*ConfigureResponse) ProtoReflect 

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

func (*ConfigureResponse) Reset 

func (x *ConfigureResponse) Reset()

func (*ConfigureResponse) String 

func (x *ConfigureResponse) String() string

type PolicyUpdate 

type PolicyUpdate struct {
	Es []*data_lifecycle.EsPolicyUpdate `protobuf:"bytes,1,rep,name=es,proto3" json:"es,omitempty" toml:"es,omitempty" mapstructure:"es,omitempty"`
	Pg []*data_lifecycle.PgPolicyUpdate `protobuf:"bytes,2,rep,name=pg,proto3" json:"pg,omitempty" toml:"pg,omitempty" mapstructure:"pg,omitempty"`
	// contains filtered or unexported fields
}

func (*PolicyUpdate) Descriptor deprecated 

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

Deprecated: Use PolicyUpdate.ProtoReflect.Descriptor instead.

func (*PolicyUpdate) GetEs 

func (x *PolicyUpdate) GetEs() []*data_lifecycle.EsPolicyUpdate

func (*PolicyUpdate) GetPg 

func (x *PolicyUpdate) GetPg() []*data_lifecycle.PgPolicyUpdate

func (*PolicyUpdate) ProtoMessage 

func (*PolicyUpdate) ProtoMessage()

func (*PolicyUpdate) ProtoReflect 

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

func (*PolicyUpdate) Reset 

func (x *PolicyUpdate) Reset()

func (*PolicyUpdate) String 

func (x *PolicyUpdate) String() string

type PurgeClient 

type PurgeClient interface {
	Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
	Configure(ctx context.Context, in *ConfigureRequest, opts ...grpc.CallOption) (*ConfigureResponse, error)
	Show(ctx context.Context, in *ShowRequest, opts ...grpc.CallOption) (*ShowResponse, error)
}

PurgeClient is the client API for Purge service.

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

func NewPurgeClient 

func NewPurgeClient(cc grpc.ClientConnInterface) PurgeClient

type PurgeServer 

type PurgeServer interface {
	Run(context.Context, *RunRequest) (*RunResponse, error)
	Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error)
	Show(context.Context, *ShowRequest) (*ShowResponse, error)
}

PurgeServer is the server API for Purge service.

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 ShowRequest 

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

func (*ShowRequest) Descriptor deprecated 

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

Deprecated: Use ShowRequest.ProtoReflect.Descriptor instead.

func (*ShowRequest) ProtoMessage 

func (*ShowRequest) ProtoMessage()

func (*ShowRequest) ProtoReflect 

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

func (*ShowRequest) Reset 

func (x *ShowRequest) Reset()

func (*ShowRequest) String 

func (x *ShowRequest) String() string

type ShowResponse 

type ShowResponse struct {
	InstanceName   string                     `` /* 167-byte string literal not displayed */
	WorkflowName   string                     `` /* 167-byte string literal not displayed */
	EsPolicies     []*data_lifecycle.EsPolicy `` /* 157-byte string literal not displayed */
	PgPolicies     []*data_lifecycle.PgPolicy `` /* 157-byte string literal not displayed */
	Recurrence     string                     `` /* 137-byte string literal not displayed */
	NextDueAt      *timestamppb.Timestamp     `` /* 156-byte string literal not displayed */
	LastEnqueuedAt *timestamppb.Timestamp     `` /* 181-byte string literal not displayed */
	Enabled        bool                       `` /* 126-byte string literal not displayed */
	LastStart      *timestamppb.Timestamp     `` /* 152-byte string literal not displayed */
	LastEnd        *timestamppb.Timestamp     `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ShowResponse) Descriptor deprecated 

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

Deprecated: Use ShowResponse.ProtoReflect.Descriptor instead.

func (*ShowResponse) GetEnabled 

func (x *ShowResponse) GetEnabled() bool

func (*ShowResponse) GetEsPolicies 

func (x *ShowResponse) GetEsPolicies() []*data_lifecycle.EsPolicy

func (*ShowResponse) GetInstanceName 

func (x *ShowResponse) GetInstanceName() string

func (*ShowResponse) GetLastEnd 

func (x *ShowResponse) GetLastEnd() *timestamppb.Timestamp

func (*ShowResponse) GetLastEnqueuedAt 

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

func (*ShowResponse) GetLastStart 

func (x *ShowResponse) GetLastStart() *timestamppb.Timestamp

func (*ShowResponse) GetNextDueAt 

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

func (*ShowResponse) GetPgPolicies 

func (x *ShowResponse) GetPgPolicies() []*data_lifecycle.PgPolicy

func (*ShowResponse) GetRecurrence 

func (x *ShowResponse) GetRecurrence() string

func (*ShowResponse) GetWorkflowName 

func (x *ShowResponse) GetWorkflowName() string

func (*ShowResponse) ProtoMessage 

func (*ShowResponse) ProtoMessage()

func (*ShowResponse) ProtoReflect 

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

func (*ShowResponse) Reset 

func (x *ShowResponse) Reset()

func (*ShowResponse) String 

func (x *ShowResponse) String() string

type UnimplementedPurgeServer 

type UnimplementedPurgeServer struct {
}

UnimplementedPurgeServer can be embedded to have forward compatible implementations.

func (*UnimplementedPurgeServer) Configure 

func (*UnimplementedPurgeServer) Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error)

func (*UnimplementedPurgeServer) Run 

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

func (*UnimplementedPurgeServer) Show 

func (*UnimplementedPurgeServer) Show(context.Context, *ShowRequest) (*ShowResponse, 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.