proto

package
v0.0.1-alpha.1 Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CheckStatus_name = map[int32]string{
	0: "UNKNOWN_CHECK_STATUS",
	1: "GREEN",
	2: "YELLOW",
	3: "RED",
}
View Source 
var CheckStatus_value = map[string]int32{
	"UNKNOWN_CHECK_STATUS": 0,
	"GREEN":                1,
	"YELLOW":               2,
	"RED":                  3,
}
View Source 
var CloudProviderType_name = map[int32]string{
	0: "UNKNOWN_CLOUD_PROVIDER_TYPE",
	1: "AWS",
	2: "DO",
}
View Source 
var CloudProviderType_value = map[string]int32{
	"UNKNOWN_CLOUD_PROVIDER_TYPE": 0,
	"AWS":                         1,
	"DO":                          2,
}

Functions

func RegisterPluginServer 

func RegisterPluginServer(s *grpc.Server, srv PluginServer)

Types

type Action 

type Action struct {
	ActionId             string   `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description          string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Action) Descriptor 

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

func (*Action) GetActionId 

func (m *Action) GetActionId() string

func (*Action) GetDescription 

func (m *Action) GetDescription() string

func (*Action) GetName 

func (m *Action) GetName() string

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) Reset 

func (m *Action) Reset()

func (*Action) String 

func (m *Action) String() string

func (*Action) XXX_DiscardUnknown 

func (m *Action) XXX_DiscardUnknown()

func (*Action) XXX_Marshal 

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

func (*Action) XXX_Merge 

func (m *Action) XXX_Merge(src proto.Message)

func (*Action) XXX_Size 

func (m *Action) XXX_Size() int

func (*Action) XXX_Unmarshal 

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

type ActionRequest 

type ActionRequest struct {
	ActionId             string   `protobuf:"bytes,1,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActionRequest) Descriptor 

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

func (*ActionRequest) GetActionId 

func (m *ActionRequest) GetActionId() string

func (*ActionRequest) ProtoMessage 

func (*ActionRequest) ProtoMessage()

func (*ActionRequest) Reset 

func (m *ActionRequest) Reset()

func (*ActionRequest) String 

func (m *ActionRequest) String() string

func (*ActionRequest) XXX_DiscardUnknown 

func (m *ActionRequest) XXX_DiscardUnknown()

func (*ActionRequest) XXX_Marshal 

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

func (*ActionRequest) XXX_Merge 

func (m *ActionRequest) XXX_Merge(src proto.Message)

func (*ActionRequest) XXX_Size 

func (m *ActionRequest) XXX_Size() int

func (*ActionRequest) XXX_Unmarshal 

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

type ActionResponse 

type ActionResponse struct {
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActionResponse) Descriptor 

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

func (*ActionResponse) GetError 

func (m *ActionResponse) GetError() string

func (*ActionResponse) ProtoMessage 

func (*ActionResponse) ProtoMessage()

func (*ActionResponse) Reset 

func (m *ActionResponse) Reset()

func (*ActionResponse) String 

func (m *ActionResponse) String() string

func (*ActionResponse) XXX_DiscardUnknown 

func (m *ActionResponse) XXX_DiscardUnknown()

func (*ActionResponse) XXX_Marshal 

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

func (*ActionResponse) XXX_Merge 

func (m *ActionResponse) XXX_Merge(src proto.Message)

func (*ActionResponse) XXX_Size 

func (m *ActionResponse) XXX_Size() int

func (*ActionResponse) XXX_Unmarshal 

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

type AwsConfig 

type AwsConfig struct {
	AccessKeyId          string   `protobuf:"bytes,1,opt,name=access_key_id,json=accessKeyId,proto3" json:"access_key_id,omitempty"`
	SecretAccessKey      string   `protobuf:"bytes,2,opt,name=secret_access_key,json=secretAccessKey,proto3" json:"secret_access_key,omitempty"`
	Region               string   `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AwsConfig) Descriptor 

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

func (*AwsConfig) GetAccessKeyId 

func (m *AwsConfig) GetAccessKeyId() string

func (*AwsConfig) GetRegion 

func (m *AwsConfig) GetRegion() string

func (*AwsConfig) GetSecretAccessKey 

func (m *AwsConfig) GetSecretAccessKey() string

func (*AwsConfig) ProtoMessage 

func (*AwsConfig) ProtoMessage()

func (*AwsConfig) Reset 

func (m *AwsConfig) Reset()

func (*AwsConfig) String 

func (m *AwsConfig) String() string

func (*AwsConfig) XXX_DiscardUnknown 

func (m *AwsConfig) XXX_DiscardUnknown()

func (*AwsConfig) XXX_Marshal 

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

func (*AwsConfig) XXX_Merge 

func (m *AwsConfig) XXX_Merge(src proto.Message)

func (*AwsConfig) XXX_Size 

func (m *AwsConfig) XXX_Size() int

func (*AwsConfig) XXX_Unmarshal 

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

type CheckRequest 

type CheckRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckRequest) Descriptor 

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

func (*CheckRequest) ProtoMessage 

func (*CheckRequest) ProtoMessage()

func (*CheckRequest) Reset 

func (m *CheckRequest) Reset()

func (*CheckRequest) String 

func (m *CheckRequest) String() string

func (*CheckRequest) XXX_DiscardUnknown 

func (m *CheckRequest) XXX_DiscardUnknown()

func (*CheckRequest) XXX_Marshal 

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

func (*CheckRequest) XXX_Merge 

func (m *CheckRequest) XXX_Merge(src proto.Message)

func (*CheckRequest) XXX_Size 

func (m *CheckRequest) XXX_Size() int

func (*CheckRequest) XXX_Unmarshal 

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

type CheckResponse 

type CheckResponse struct {
	Result               *CheckResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Error                string       `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CheckResponse) Descriptor 

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

func (*CheckResponse) GetError 

func (m *CheckResponse) GetError() string

func (*CheckResponse) GetResult 

func (m *CheckResponse) GetResult() *CheckResult

func (*CheckResponse) ProtoMessage 

func (*CheckResponse) ProtoMessage()

func (*CheckResponse) Reset 

func (m *CheckResponse) Reset()

func (*CheckResponse) String 

func (m *CheckResponse) String() string

func (*CheckResponse) XXX_DiscardUnknown 

func (m *CheckResponse) XXX_DiscardUnknown()

func (*CheckResponse) XXX_Marshal 

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

func (*CheckResponse) XXX_Merge 

func (m *CheckResponse) XXX_Merge(src proto.Message)

func (*CheckResponse) XXX_Size 

func (m *CheckResponse) XXX_Size() int

func (*CheckResponse) XXX_Unmarshal 

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

type CheckResult 

type CheckResult struct {
	ExecutionStatus string      `protobuf:"bytes,1,opt,name=execution_status,json=executionStatus,proto3" json:"execution_status,omitempty"`
	Status          CheckStatus `protobuf:"varint,2,opt,name=status,proto3,enum=proto.CheckStatus" json:"status,omitempty"`
	Name            string      `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// TODO: temporary solution need to be redesigned.
	Description          *any.Any  `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Actions              []*Action `protobuf:"bytes,5,rep,name=actions,proto3" json:"actions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*CheckResult) Descriptor 

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

func (*CheckResult) GetActions 

func (m *CheckResult) GetActions() []*Action

func (*CheckResult) GetDescription 

func (m *CheckResult) GetDescription() *any.Any

func (*CheckResult) GetExecutionStatus 

func (m *CheckResult) GetExecutionStatus() string

func (*CheckResult) GetName 

func (m *CheckResult) GetName() string

func (*CheckResult) GetStatus 

func (m *CheckResult) GetStatus() CheckStatus

func (*CheckResult) ProtoMessage 

func (*CheckResult) ProtoMessage()

func (*CheckResult) Reset 

func (m *CheckResult) Reset()

func (*CheckResult) String 

func (m *CheckResult) String() string

func (*CheckResult) XXX_DiscardUnknown 

func (m *CheckResult) XXX_DiscardUnknown()

func (*CheckResult) XXX_Marshal 

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

func (*CheckResult) XXX_Merge 

func (m *CheckResult) XXX_Merge(src proto.Message)

func (*CheckResult) XXX_Size 

func (m *CheckResult) XXX_Size() int

func (*CheckResult) XXX_Unmarshal 

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

type CheckStatus 

type CheckStatus int32
const (
	CheckStatus_UNKNOWN_CHECK_STATUS CheckStatus = 0
	CheckStatus_GREEN                CheckStatus = 1
	CheckStatus_YELLOW               CheckStatus = 2
	CheckStatus_RED                  CheckStatus = 3
)

func (CheckStatus) EnumDescriptor 

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

func (CheckStatus) String 

func (x CheckStatus) String() string

type CloudProviderType 

type CloudProviderType int32
const (
	CloudProviderType_UNKNOWN_CLOUD_PROVIDER_TYPE CloudProviderType = 0
	CloudProviderType_AWS                         CloudProviderType = 1
	CloudProviderType_DO                          CloudProviderType = 2
)

func (CloudProviderType) EnumDescriptor 

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

func (CloudProviderType) String 

func (x CloudProviderType) String() string

type DoConfig 

type DoConfig struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

not implemented yet

func (*DoConfig) Descriptor 

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

func (*DoConfig) ProtoMessage 

func (*DoConfig) ProtoMessage()

func (*DoConfig) Reset 

func (m *DoConfig) Reset()

func (*DoConfig) String 

func (m *DoConfig) String() string

func (*DoConfig) XXX_DiscardUnknown 

func (m *DoConfig) XXX_DiscardUnknown()

func (*DoConfig) XXX_Marshal 

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

func (*DoConfig) XXX_Merge 

func (m *DoConfig) XXX_Merge(src proto.Message)

func (*DoConfig) XXX_Size 

func (m *DoConfig) XXX_Size() int

func (*DoConfig) XXX_Unmarshal 

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

type PluginClient 

type PluginClient interface {
	Info(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PluginInfo, error)
	Check(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error)
	Action(ctx context.Context, in *ActionRequest, opts ...grpc.CallOption) (*ActionResponse, error)
	Configure(ctx context.Context, in *PluginConfig, opts ...grpc.CallOption) (*empty.Empty, error)
	//Graceful Shutdown Plugin
	Stop(ctx context.Context, in *Stop_Request, opts ...grpc.CallOption) (*Stop_Response, error)
}

PluginClient is the client API for Plugin service.

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

func NewPluginClient 

func NewPluginClient(cc *grpc.ClientConn) PluginClient

type PluginConfig 

type PluginConfig struct {
	ProviderType CloudProviderType `` /* 127-byte string literal not displayed */
	// Types that are valid to be assigned to CloudProviderConfig:
	//	*PluginConfig_DoConfig
	//	*PluginConfig_AwsConfig
	CloudProviderConfig  isPluginConfig_CloudProviderConfig `protobuf_oneof:"cloud_provider_config"`
	MetricsServerUri     string                             `protobuf:"bytes,5,opt,name=metrics_server_uri,json=metricsServerUri,proto3" json:"metrics_server_uri,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

plugin instance is running inside k8s cluster, consequently: k8s api server doesn't need to be configured and is accessible through k8s service discovery AWS credentials need to be configured

func (*PluginConfig) Descriptor 

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

func (*PluginConfig) GetAwsConfig 

func (m *PluginConfig) GetAwsConfig() *AwsConfig

func (*PluginConfig) GetCloudProviderConfig 

func (m *PluginConfig) GetCloudProviderConfig() isPluginConfig_CloudProviderConfig

func (*PluginConfig) GetDoConfig 

func (m *PluginConfig) GetDoConfig() *DoConfig

func (*PluginConfig) GetMetricsServerUri 

func (m *PluginConfig) GetMetricsServerUri() string

func (*PluginConfig) GetProviderType 

func (m *PluginConfig) GetProviderType() CloudProviderType

func (*PluginConfig) ProtoMessage 

func (*PluginConfig) ProtoMessage()

func (*PluginConfig) Reset 

func (m *PluginConfig) Reset()

func (*PluginConfig) String 

func (m *PluginConfig) String() string

func (*PluginConfig) XXX_DiscardUnknown 

func (m *PluginConfig) XXX_DiscardUnknown()

func (*PluginConfig) XXX_Marshal 

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

func (*PluginConfig) XXX_Merge 

func (m *PluginConfig) XXX_Merge(src proto.Message)

func (*PluginConfig) XXX_OneofFuncs 

func (*PluginConfig) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*PluginConfig) XXX_Size 

func (m *PluginConfig) XXX_Size() int

func (*PluginConfig) XXX_Unmarshal 

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

type PluginConfig_AwsConfig 

type PluginConfig_AwsConfig struct {
	AwsConfig *AwsConfig `protobuf:"bytes,3,opt,name=aws_config,json=awsConfig,proto3,oneof"`
}

type PluginConfig_DoConfig 

type PluginConfig_DoConfig struct {
	DoConfig *DoConfig `protobuf:"bytes,2,opt,name=do_config,json=doConfig,proto3,oneof"`
}

type PluginInfo 

type PluginInfo struct {
	//unique ID of plugin
	//basically it is slugged URI of plugin repository name e. g. supergiant-underutilized-nodes
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	//plugin version in semver format
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	//short name of plugin
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// detailed plugin description
	Description          string   `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PluginInfo) Descriptor 

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

func (*PluginInfo) GetDescription 

func (m *PluginInfo) GetDescription() string

func (*PluginInfo) GetId 

func (m *PluginInfo) GetId() string

func (*PluginInfo) GetName 

func (m *PluginInfo) GetName() string

func (*PluginInfo) GetVersion 

func (m *PluginInfo) GetVersion() string

func (*PluginInfo) ProtoMessage 

func (*PluginInfo) ProtoMessage()

func (*PluginInfo) Reset 

func (m *PluginInfo) Reset()

func (*PluginInfo) String 

func (m *PluginInfo) String() string

func (*PluginInfo) XXX_DiscardUnknown 

func (m *PluginInfo) XXX_DiscardUnknown()

func (*PluginInfo) XXX_Marshal 

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

func (*PluginInfo) XXX_Merge 

func (m *PluginInfo) XXX_Merge(src proto.Message)

func (*PluginInfo) XXX_Size 

func (m *PluginInfo) XXX_Size() int

func (*PluginInfo) XXX_Unmarshal 

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

type PluginServer 

type PluginServer interface {
	Info(context.Context, *empty.Empty) (*PluginInfo, error)
	Check(context.Context, *CheckRequest) (*CheckResponse, error)
	Action(context.Context, *ActionRequest) (*ActionResponse, error)
	Configure(context.Context, *PluginConfig) (*empty.Empty, error)
	//Graceful Shutdown Plugin
	Stop(context.Context, *Stop_Request) (*Stop_Response, error)
}

PluginServer is the server API for Plugin service.

type Stop 

type Stop struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Stop) Descriptor 

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

func (*Stop) ProtoMessage 

func (*Stop) ProtoMessage()

func (*Stop) Reset 

func (m *Stop) Reset()

func (*Stop) String 

func (m *Stop) String() string

func (*Stop) XXX_DiscardUnknown 

func (m *Stop) XXX_DiscardUnknown()

func (*Stop) XXX_Marshal 

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

func (*Stop) XXX_Merge 

func (m *Stop) XXX_Merge(src proto.Message)

func (*Stop) XXX_Size 

func (m *Stop) XXX_Size() int

func (*Stop) XXX_Unmarshal 

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

type Stop_Request 

type Stop_Request struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Stop_Request) Descriptor 

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

func (*Stop_Request) ProtoMessage 

func (*Stop_Request) ProtoMessage()

func (*Stop_Request) Reset 

func (m *Stop_Request) Reset()

func (*Stop_Request) String 

func (m *Stop_Request) String() string

func (*Stop_Request) XXX_DiscardUnknown 

func (m *Stop_Request) XXX_DiscardUnknown()

func (*Stop_Request) XXX_Marshal 

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

func (*Stop_Request) XXX_Merge 

func (m *Stop_Request) XXX_Merge(src proto.Message)

func (*Stop_Request) XXX_Size 

func (m *Stop_Request) XXX_Size() int

func (*Stop_Request) XXX_Unmarshal 

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

type Stop_Response 

type Stop_Response struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Stop_Response) Descriptor 

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

func (*Stop_Response) GetError 

func (m *Stop_Response) GetError() string

func (*Stop_Response) ProtoMessage 

func (*Stop_Response) ProtoMessage()

func (*Stop_Response) Reset 

func (m *Stop_Response) Reset()

func (*Stop_Response) String 

func (m *Stop_Response) String() string

func (*Stop_Response) XXX_DiscardUnknown 

func (m *Stop_Response) XXX_DiscardUnknown()

func (*Stop_Response) XXX_Marshal 

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

func (*Stop_Response) XXX_Merge 

func (m *Stop_Response) XXX_Merge(src proto.Message)

func (*Stop_Response) XXX_Size 

func (m *Stop_Response) XXX_Size() int

func (*Stop_Response) XXX_Unmarshal 

func (m *Stop_Response) 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.