podstore

package
v0.0.0-...-8223eb1 Latest Latest
Warning

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

 Go to latest Published: Jan 14, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package podstore is a generated protocol buffer package.

It is generated from these files: 

pkg/grpc/podstore/protos/podstore.proto

It has these top-level messages: 

SchedulePodRequest
SchedulePodResponse
WatchPodStatusRequest
PodStatusResponse
ProcessStatus
ExitStatus
UnschedulePodRequest
UnschedulePodResponse
ListPodStatusRequest
ListPodStatusResponse
DeletePodStatusRequest
DeletePodStatusResponse
MarkPodFailedRequest
MarkPodFailedResponse

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterP2PodStoreServer 

func RegisterP2PodStoreServer(s *grpc.Server, srv P2PodStoreServer)

Types

type DeletePodStatusRequest 

type DeletePodStatusRequest struct {
	PodUniqueKey string `protobuf:"bytes,1,opt,name=pod_unique_key,json=podUniqueKey" json:"pod_unique_key,omitempty"`
}

func (*DeletePodStatusRequest) Descriptor 

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

func (*DeletePodStatusRequest) GetPodUniqueKey 

func (m *DeletePodStatusRequest) GetPodUniqueKey() string

func (*DeletePodStatusRequest) ProtoMessage 

func (*DeletePodStatusRequest) ProtoMessage()

func (*DeletePodStatusRequest) Reset 

func (m *DeletePodStatusRequest) Reset()

func (*DeletePodStatusRequest) String 

func (m *DeletePodStatusRequest) String() string

type DeletePodStatusResponse 

type DeletePodStatusResponse struct {
}

func (*DeletePodStatusResponse) Descriptor 

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

func (*DeletePodStatusResponse) ProtoMessage 

func (*DeletePodStatusResponse) ProtoMessage()

func (*DeletePodStatusResponse) Reset 

func (m *DeletePodStatusResponse) Reset()

func (*DeletePodStatusResponse) String 

func (m *DeletePodStatusResponse) String() string

type ExitStatus 

type ExitStatus struct {
	ExitTime   int64 `protobuf:"varint,1,opt,name=exit_time,json=exitTime" json:"exit_time,omitempty"`
	ExitCode   int64 `protobuf:"varint,2,opt,name=exit_code,json=exitCode" json:"exit_code,omitempty"`
	ExitStatus int64 `protobuf:"varint,3,opt,name=exit_status,json=exitStatus" json:"exit_status,omitempty"`
}

func (*ExitStatus) Descriptor 

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

func (*ExitStatus) GetExitCode 

func (m *ExitStatus) GetExitCode() int64

func (*ExitStatus) GetExitStatus 

func (m *ExitStatus) GetExitStatus() int64

func (*ExitStatus) GetExitTime 

func (m *ExitStatus) GetExitTime() int64

func (*ExitStatus) ProtoMessage 

func (*ExitStatus) ProtoMessage()

func (*ExitStatus) Reset 

func (m *ExitStatus) Reset()

func (*ExitStatus) String 

func (m *ExitStatus) String() string

type ListPodStatusRequest 

type ListPodStatusRequest struct {
	StatusNamespace string `protobuf:"bytes,1,opt,name=status_namespace,json=statusNamespace" json:"status_namespace,omitempty"`
}

func (*ListPodStatusRequest) Descriptor 

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

func (*ListPodStatusRequest) GetStatusNamespace 

func (m *ListPodStatusRequest) GetStatusNamespace() string

func (*ListPodStatusRequest) ProtoMessage 

func (*ListPodStatusRequest) ProtoMessage()

func (*ListPodStatusRequest) Reset 

func (m *ListPodStatusRequest) Reset()

func (*ListPodStatusRequest) String 

func (m *ListPodStatusRequest) String() string

type ListPodStatusResponse 

type ListPodStatusResponse struct {
	PodStatuses map[string]*PodStatusResponse `` /* 161-byte string literal not displayed */
}

func (*ListPodStatusResponse) Descriptor 

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

func (*ListPodStatusResponse) GetPodStatuses 

func (m *ListPodStatusResponse) GetPodStatuses() map[string]*PodStatusResponse

func (*ListPodStatusResponse) ProtoMessage 

func (*ListPodStatusResponse) ProtoMessage()

func (*ListPodStatusResponse) Reset 

func (m *ListPodStatusResponse) Reset()

func (*ListPodStatusResponse) String 

func (m *ListPodStatusResponse) String() string

type MarkPodFailedRequest 

type MarkPodFailedRequest struct {
	PodUniqueKey string `protobuf:"bytes,1,opt,name=pod_unique_key,json=podUniqueKey" json:"pod_unique_key,omitempty"`
}

func (*MarkPodFailedRequest) Descriptor 

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

func (*MarkPodFailedRequest) GetPodUniqueKey 

func (m *MarkPodFailedRequest) GetPodUniqueKey() string

func (*MarkPodFailedRequest) ProtoMessage 

func (*MarkPodFailedRequest) ProtoMessage()

func (*MarkPodFailedRequest) Reset 

func (m *MarkPodFailedRequest) Reset()

func (*MarkPodFailedRequest) String 

func (m *MarkPodFailedRequest) String() string

type MarkPodFailedResponse 

type MarkPodFailedResponse struct {
}

func (*MarkPodFailedResponse) Descriptor 

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

func (*MarkPodFailedResponse) ProtoMessage 

func (*MarkPodFailedResponse) ProtoMessage()

func (*MarkPodFailedResponse) Reset 

func (m *MarkPodFailedResponse) Reset()

func (*MarkPodFailedResponse) String 

func (m *MarkPodFailedResponse) String() string

type P2PodStoreClient 

type P2PodStoreClient interface {
	// Schedules a uuid pod on a host
	SchedulePod(ctx context.Context, in *SchedulePodRequest, opts ...grpc.CallOption) (*SchedulePodResponse, error)
	WatchPodStatus(ctx context.Context, in *WatchPodStatusRequest, opts ...grpc.CallOption) (P2PodStore_WatchPodStatusClient, error)
	UnschedulePod(ctx context.Context, in *UnschedulePodRequest, opts ...grpc.CallOption) (*UnschedulePodResponse, error)
	ListPodStatus(ctx context.Context, in *ListPodStatusRequest, opts ...grpc.CallOption) (*ListPodStatusResponse, error)
	DeletePodStatus(ctx context.Context, in *DeletePodStatusRequest, opts ...grpc.CallOption) (*DeletePodStatusResponse, error)
	MarkPodFailed(ctx context.Context, in *MarkPodFailedRequest, opts ...grpc.CallOption) (*MarkPodFailedResponse, error)
}

func NewP2PodStoreClient 

func NewP2PodStoreClient(cc *grpc.ClientConn) P2PodStoreClient

type P2PodStoreServer 

type P2PodStoreServer interface {
	// Schedules a uuid pod on a host
	SchedulePod(context.Context, *SchedulePodRequest) (*SchedulePodResponse, error)
	WatchPodStatus(*WatchPodStatusRequest, P2PodStore_WatchPodStatusServer) error
	UnschedulePod(context.Context, *UnschedulePodRequest) (*UnschedulePodResponse, error)
	ListPodStatus(context.Context, *ListPodStatusRequest) (*ListPodStatusResponse, error)
	DeletePodStatus(context.Context, *DeletePodStatusRequest) (*DeletePodStatusResponse, error)
	MarkPodFailed(context.Context, *MarkPodFailedRequest) (*MarkPodFailedResponse, error)
}

type P2PodStore_WatchPodStatusClient 

type P2PodStore_WatchPodStatusClient interface {
	Recv() (*PodStatusResponse, error)
	grpc.ClientStream
}

type P2PodStore_WatchPodStatusServer 

type P2PodStore_WatchPodStatusServer interface {
	Send(*PodStatusResponse) error
	grpc.ServerStream
}

type PodStatusResponse 

type PodStatusResponse struct {
	Manifest        string           `protobuf:"bytes,1,opt,name=manifest" json:"manifest,omitempty"`
	PodState        string           `protobuf:"bytes,2,opt,name=pod_state,json=podState" json:"pod_state,omitempty"`
	ProcessStatuses []*ProcessStatus `protobuf:"bytes,3,rep,name=process_statuses,json=processStatuses" json:"process_statuses,omitempty"`
}

func (*PodStatusResponse) Descriptor 

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

func (*PodStatusResponse) GetManifest 

func (m *PodStatusResponse) GetManifest() string

func (*PodStatusResponse) GetPodState 

func (m *PodStatusResponse) GetPodState() string

func (*PodStatusResponse) GetProcessStatuses 

func (m *PodStatusResponse) GetProcessStatuses() []*ProcessStatus

func (*PodStatusResponse) ProtoMessage 

func (*PodStatusResponse) ProtoMessage()

func (*PodStatusResponse) Reset 

func (m *PodStatusResponse) Reset()

func (*PodStatusResponse) String 

func (m *PodStatusResponse) String() string

type ProcessStatus 

type ProcessStatus struct {
	LaunchableId string      `protobuf:"bytes,1,opt,name=launchable_id,json=launchableId" json:"launchable_id,omitempty"`
	EntryPoint   string      `protobuf:"bytes,2,opt,name=entry_point,json=entryPoint" json:"entry_point,omitempty"`
	LastExit     *ExitStatus `protobuf:"bytes,3,opt,name=last_exit,json=lastExit" json:"last_exit,omitempty"`
}

func (*ProcessStatus) Descriptor 

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

func (*ProcessStatus) GetEntryPoint 

func (m *ProcessStatus) GetEntryPoint() string

func (*ProcessStatus) GetLastExit 

func (m *ProcessStatus) GetLastExit() *ExitStatus

func (*ProcessStatus) GetLaunchableId 

func (m *ProcessStatus) GetLaunchableId() string

func (*ProcessStatus) ProtoMessage 

func (*ProcessStatus) ProtoMessage()

func (*ProcessStatus) Reset 

func (m *ProcessStatus) Reset()

func (*ProcessStatus) String 

func (m *ProcessStatus) String() string

type SchedulePodRequest 

type SchedulePodRequest struct {
	Manifest string `protobuf:"bytes,1,opt,name=manifest" json:"manifest,omitempty"`
	NodeName string `protobuf:"bytes,2,opt,name=node_name,json=nodeName" json:"node_name,omitempty"`
}

func (*SchedulePodRequest) Descriptor 

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

func (*SchedulePodRequest) GetManifest 

func (m *SchedulePodRequest) GetManifest() string

func (*SchedulePodRequest) GetNodeName 

func (m *SchedulePodRequest) GetNodeName() string

func (*SchedulePodRequest) ProtoMessage 

func (*SchedulePodRequest) ProtoMessage()

func (*SchedulePodRequest) Reset 

func (m *SchedulePodRequest) Reset()

func (*SchedulePodRequest) String 

func (m *SchedulePodRequest) String() string

type SchedulePodResponse 

type SchedulePodResponse struct {
	PodUniqueKey string `protobuf:"bytes,1,opt,name=pod_unique_key,json=podUniqueKey" json:"pod_unique_key,omitempty"`
}

func (*SchedulePodResponse) Descriptor 

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

func (*SchedulePodResponse) GetPodUniqueKey 

func (m *SchedulePodResponse) GetPodUniqueKey() string

func (*SchedulePodResponse) ProtoMessage 

func (*SchedulePodResponse) ProtoMessage()

func (*SchedulePodResponse) Reset 

func (m *SchedulePodResponse) Reset()

func (*SchedulePodResponse) String 

func (m *SchedulePodResponse) String() string

type UnschedulePodRequest 

type UnschedulePodRequest struct {
	PodUniqueKey string `protobuf:"bytes,1,opt,name=pod_unique_key,json=podUniqueKey" json:"pod_unique_key,omitempty"`
}

func (*UnschedulePodRequest) Descriptor 

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

func (*UnschedulePodRequest) GetPodUniqueKey 

func (m *UnschedulePodRequest) GetPodUniqueKey() string

func (*UnschedulePodRequest) ProtoMessage 

func (*UnschedulePodRequest) ProtoMessage()

func (*UnschedulePodRequest) Reset 

func (m *UnschedulePodRequest) Reset()

func (*UnschedulePodRequest) String 

func (m *UnschedulePodRequest) String() string

type UnschedulePodResponse 

type UnschedulePodResponse struct {
}

func (*UnschedulePodResponse) Descriptor 

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

func (*UnschedulePodResponse) ProtoMessage 

func (*UnschedulePodResponse) ProtoMessage()

func (*UnschedulePodResponse) Reset 

func (m *UnschedulePodResponse) Reset()

func (*UnschedulePodResponse) String 

func (m *UnschedulePodResponse) String() string

type WatchPodStatusRequest 

type WatchPodStatusRequest struct {
	PodUniqueKey    string `protobuf:"bytes,1,opt,name=pod_unique_key,json=podUniqueKey" json:"pod_unique_key,omitempty"`
	StatusNamespace string `protobuf:"bytes,3,opt,name=status_namespace,json=statusNamespace" json:"status_namespace,omitempty"`
	WaitForExists   bool   `protobuf:"varint,4,opt,name=wait_for_exists,json=waitForExists" json:"wait_for_exists,omitempty"`
}

func (*WatchPodStatusRequest) Descriptor 

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

func (*WatchPodStatusRequest) GetPodUniqueKey 

func (m *WatchPodStatusRequest) GetPodUniqueKey() string

func (*WatchPodStatusRequest) GetStatusNamespace 

func (m *WatchPodStatusRequest) GetStatusNamespace() string

func (*WatchPodStatusRequest) GetWaitForExists 

func (m *WatchPodStatusRequest) GetWaitForExists() bool

func (*WatchPodStatusRequest) ProtoMessage 

func (*WatchPodStatusRequest) ProtoMessage()

func (*WatchPodStatusRequest) Reset 

func (m *WatchPodStatusRequest) Reset()

func (*WatchPodStatusRequest) String 

func (m *WatchPodStatusRequest) String() string

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.