 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- Variables
- func RegisterPurgeServer(s *grpc.Server, srv PurgeServer)
- type ConfigureRequest
- func (*ConfigureRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigureRequest) GetEnabled() bool
- func (x *ConfigureRequest) GetPolicyUpdate() *PolicyUpdate
- func (x *ConfigureRequest) GetRecurrence() string
- func (*ConfigureRequest) ProtoMessage()
- func (x *ConfigureRequest) ProtoReflect() protoreflect.Message
- func (x *ConfigureRequest) Reset()
- func (x *ConfigureRequest) String() string
 
- type ConfigureResponse
- type PolicyUpdate
- func (*PolicyUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *PolicyUpdate) GetEs() []*data_lifecycle.EsPolicyUpdate
- func (x *PolicyUpdate) GetPg() []*data_lifecycle.PgPolicyUpdate
- func (*PolicyUpdate) ProtoMessage()
- func (x *PolicyUpdate) ProtoReflect() protoreflect.Message
- func (x *PolicyUpdate) Reset()
- func (x *PolicyUpdate) String() string
 
- type PurgeClient
- type PurgeServer
- type RunRequest
- type RunResponse
- type ShowRequest
- type ShowResponse
- func (*ShowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ShowResponse) GetEnabled() bool
- func (x *ShowResponse) GetEsPolicies() []*data_lifecycle.EsPolicy
- func (x *ShowResponse) GetInstanceName() string
- func (x *ShowResponse) GetLastEnd() *timestamppb.Timestamp
- func (x *ShowResponse) GetLastEnqueuedAt() *timestamppb.Timestamp
- func (x *ShowResponse) GetLastStart() *timestamppb.Timestamp
- func (x *ShowResponse) GetNextDueAt() *timestamppb.Timestamp
- func (x *ShowResponse) GetPgPolicies() []*data_lifecycle.PgPolicy
- func (x *ShowResponse) GetRecurrence() string
- func (x *ShowResponse) GetWorkflowName() string
- func (*ShowResponse) ProtoMessage()
- func (x *ShowResponse) ProtoReflect() protoreflect.Message
- func (x *ShowResponse) Reset()
- func (x *ShowResponse) String() string
 
- type UnimplementedPurgeServer
Constants ¶
This section is empty.
Variables ¶
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)