data_lifecycle

package
v0.0.0-...-0490640 Latest Latest
Warning

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

 Go to latest Published: May 16, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var PurgeStatus_StatusCode_name = map[int32]string{
	0: "FAILED",
	1: "SUCCESS",
}
View Source 
var PurgeStatus_StatusCode_value = map[string]int32{
	"FAILED":  0,
	"SUCCESS": 1,
}

Functions

func RegisterDataLifecycleManageableServer 

func RegisterDataLifecycleManageableServer(s *grpc.Server, srv DataLifecycleManageableServer)

func RegisterDataLifecycleServer 

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

Types

type DataLifecycleClient 

type DataLifecycleClient interface {
	// Health checks and metadata
	Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
	TriggerPurge(ctx context.Context, in *TriggerPurgeRequest, opts ...grpc.CallOption) (*TriggerPurgeResponse, 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.ClientConn) DataLifecycleClient

type DataLifecycleManageableClient 

type DataLifecycleManageableClient interface {
	// We could make this streaming and return how much is
	// finished
	Purge(ctx context.Context, in *PurgeRequest, opts ...grpc.CallOption) (*PurgeResponse, error)
}

DataLifecycleManageableClient is the client API for DataLifecycleManageable service.

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

func NewDataLifecycleManageableClient 

func NewDataLifecycleManageableClient(cc *grpc.ClientConn) DataLifecycleManageableClient

type DataLifecycleManageableServer 

type DataLifecycleManageableServer interface {
	// We could make this streaming and return how much is
	// finished
	Purge(context.Context, *PurgeRequest) (*PurgeResponse, error)
}

DataLifecycleManageableServer is the server API for DataLifecycleManageable service.

type DataLifecycleServer 

type DataLifecycleServer interface {
	// Health checks and metadata
	Version(context.Context, *VersionRequest) (*VersionResponse, error)
	TriggerPurge(context.Context, *TriggerPurgeRequest) (*TriggerPurgeResponse, error)
}

DataLifecycleServer is the server API for DataLifecycle service.

type PurgeRequest 

type PurgeRequest struct {
	// This id must be managed. If a request with a duplicate id comes in,
	// the down stream service should prefer waiting for that id to complete
	// rather than redoing the work.
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*PurgeRequest) Descriptor 

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

func (*PurgeRequest) GetId 

func (m *PurgeRequest) GetId() string

func (*PurgeRequest) ProtoMessage 

func (*PurgeRequest) ProtoMessage()

func (*PurgeRequest) Reset 

func (m *PurgeRequest) Reset()

func (*PurgeRequest) String 

func (m *PurgeRequest) String() string

func (*PurgeRequest) XXX_DiscardUnknown 

func (m *PurgeRequest) XXX_DiscardUnknown()

func (*PurgeRequest) XXX_Marshal 

func (m *PurgeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PurgeRequest) XXX_Merge 

func (dst *PurgeRequest) XXX_Merge(src proto.Message)

func (*PurgeRequest) XXX_Size 

func (m *PurgeRequest) XXX_Size() int

func (*PurgeRequest) XXX_Unmarshal 

func (m *PurgeRequest) XXX_Unmarshal(b []byte) error

type PurgeResponse 

type PurgeResponse struct {
	Id                   string                  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	ComponentStatus      map[string]*PurgeStatus `` /* 270-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte                  `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32                   `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*PurgeResponse) Descriptor 

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

func (*PurgeResponse) GetComponentStatus 

func (m *PurgeResponse) GetComponentStatus() map[string]*PurgeStatus

func (*PurgeResponse) GetId 

func (m *PurgeResponse) GetId() string

func (*PurgeResponse) ProtoMessage 

func (*PurgeResponse) ProtoMessage()

func (*PurgeResponse) Reset 

func (m *PurgeResponse) Reset()

func (*PurgeResponse) String 

func (m *PurgeResponse) String() string

func (*PurgeResponse) XXX_DiscardUnknown 

func (m *PurgeResponse) XXX_DiscardUnknown()

func (*PurgeResponse) XXX_Marshal 

func (m *PurgeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PurgeResponse) XXX_Merge 

func (dst *PurgeResponse) XXX_Merge(src proto.Message)

func (*PurgeResponse) XXX_Size 

func (m *PurgeResponse) XXX_Size() int

func (*PurgeResponse) XXX_Unmarshal 

func (m *PurgeResponse) XXX_Unmarshal(b []byte) error

type PurgeStatus 

type PurgeStatus struct {
	Status               PurgeStatus_StatusCode `` /* 186-byte string literal not displayed */
	Msg                  string                 `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty" toml:"msg,omitempty" mapstructure:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte                 `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32                  `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*PurgeStatus) Descriptor 

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

func (*PurgeStatus) GetMsg 

func (m *PurgeStatus) GetMsg() string

func (*PurgeStatus) GetStatus 

func (m *PurgeStatus) GetStatus() PurgeStatus_StatusCode

func (*PurgeStatus) ProtoMessage 

func (*PurgeStatus) ProtoMessage()

func (*PurgeStatus) Reset 

func (m *PurgeStatus) Reset()

func (*PurgeStatus) String 

func (m *PurgeStatus) String() string

func (*PurgeStatus) XXX_DiscardUnknown 

func (m *PurgeStatus) XXX_DiscardUnknown()

func (*PurgeStatus) XXX_Marshal 

func (m *PurgeStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PurgeStatus) XXX_Merge 

func (dst *PurgeStatus) XXX_Merge(src proto.Message)

func (*PurgeStatus) XXX_Size 

func (m *PurgeStatus) XXX_Size() int

func (*PurgeStatus) XXX_Unmarshal 

func (m *PurgeStatus) XXX_Unmarshal(b []byte) error

type PurgeStatus_StatusCode 

type PurgeStatus_StatusCode int32
const (
	PurgeStatus_FAILED  PurgeStatus_StatusCode = 0
	PurgeStatus_SUCCESS PurgeStatus_StatusCode = 1
)

func (PurgeStatus_StatusCode) EnumDescriptor 

func (PurgeStatus_StatusCode) EnumDescriptor() ([]byte, []int)

func (PurgeStatus_StatusCode) String 

func (x PurgeStatus_StatusCode) String() string

type TriggerPurgeRequest 

type TriggerPurgeRequest struct {
	// Id is a uuid to reference this request. A request with
	// an existing id may reuse the result of the already triggered
	// purge request.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	// Optional service_name. If provided, the purge will be restricted to this service
	ServiceName          string   `` /* 162-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*TriggerPurgeRequest) Descriptor 

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

func (*TriggerPurgeRequest) GetId 

func (m *TriggerPurgeRequest) GetId() string

func (*TriggerPurgeRequest) GetServiceName 

func (m *TriggerPurgeRequest) GetServiceName() string

func (*TriggerPurgeRequest) ProtoMessage 

func (*TriggerPurgeRequest) ProtoMessage()

func (*TriggerPurgeRequest) Reset 

func (m *TriggerPurgeRequest) Reset()

func (*TriggerPurgeRequest) String 

func (m *TriggerPurgeRequest) String() string

func (*TriggerPurgeRequest) XXX_DiscardUnknown 

func (m *TriggerPurgeRequest) XXX_DiscardUnknown()

func (*TriggerPurgeRequest) XXX_Marshal 

func (m *TriggerPurgeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TriggerPurgeRequest) XXX_Merge 

func (dst *TriggerPurgeRequest) XXX_Merge(src proto.Message)

func (*TriggerPurgeRequest) XXX_Size 

func (m *TriggerPurgeRequest) XXX_Size() int

func (*TriggerPurgeRequest) XXX_Unmarshal 

func (m *TriggerPurgeRequest) XXX_Unmarshal(b []byte) error

type TriggerPurgeResponse 

type TriggerPurgeResponse struct {
	// The response returned by each service
	Responses            map[string]*PurgeResponse `` /* 221-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                  `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte                    `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32                     `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*TriggerPurgeResponse) Descriptor 

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

func (*TriggerPurgeResponse) GetResponses 

func (m *TriggerPurgeResponse) GetResponses() map[string]*PurgeResponse

func (*TriggerPurgeResponse) ProtoMessage 

func (*TriggerPurgeResponse) ProtoMessage()

func (*TriggerPurgeResponse) Reset 

func (m *TriggerPurgeResponse) Reset()

func (*TriggerPurgeResponse) String 

func (m *TriggerPurgeResponse) String() string

func (*TriggerPurgeResponse) XXX_DiscardUnknown 

func (m *TriggerPurgeResponse) XXX_DiscardUnknown()

func (*TriggerPurgeResponse) XXX_Marshal 

func (m *TriggerPurgeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TriggerPurgeResponse) XXX_Merge 

func (dst *TriggerPurgeResponse) XXX_Merge(src proto.Message)

func (*TriggerPurgeResponse) XXX_Size 

func (m *TriggerPurgeResponse) XXX_Size() int

func (*TriggerPurgeResponse) XXX_Unmarshal 

func (m *TriggerPurgeResponse) XXX_Unmarshal(b []byte) error

type VersionRequest 

type VersionRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*VersionRequest) Descriptor 

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

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) Reset 

func (m *VersionRequest) Reset()

func (*VersionRequest) String 

func (m *VersionRequest) String() string

func (*VersionRequest) XXX_DiscardUnknown 

func (m *VersionRequest) XXX_DiscardUnknown()

func (*VersionRequest) XXX_Marshal 

func (m *VersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionRequest) XXX_Merge 

func (dst *VersionRequest) XXX_Merge(src proto.Message)

func (*VersionRequest) XXX_Size 

func (m *VersionRequest) XXX_Size() int

func (*VersionRequest) XXX_Unmarshal 

func (m *VersionRequest) XXX_Unmarshal(b []byte) error

type VersionResponse 

type VersionResponse struct {
	Version              string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty" toml:"version,omitempty" mapstructure:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_unrecognized     []byte   `json:"-" toml:"-" mapstructure:"-,omitempty"`
	XXX_sizecache        int32    `json:"-" toml:"-" mapstructure:"-,omitempty"`
}

func (*VersionResponse) Descriptor 

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

func (*VersionResponse) GetVersion 

func (m *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) Reset 

func (m *VersionResponse) Reset()

func (*VersionResponse) String 

func (m *VersionResponse) String() string

func (*VersionResponse) XXX_DiscardUnknown 

func (m *VersionResponse) XXX_DiscardUnknown()

func (*VersionResponse) XXX_Marshal 

func (m *VersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionResponse) XXX_Merge 

func (dst *VersionResponse) XXX_Merge(src proto.Message)

func (*VersionResponse) XXX_Size 

func (m *VersionResponse) XXX_Size() int

func (*VersionResponse) XXX_Unmarshal 

func (m *VersionResponse) XXX_Unmarshal(b []byte) 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.