admin

Documentation

Index

• Variables
• func RegisterAPIServer(s *grpc.Server, srv APIServer)
• type APIClient
  • func NewAPIClient(cc *grpc.ClientConn) APIClient
• type APIServer
• type ClusterInfo
  • func (*ClusterInfo) Descriptor() ([]byte, []int)
  • func (m *ClusterInfo) GetDeploymentID() string
  • func (m *ClusterInfo) GetID() string
  • func (m *ClusterInfo) GetVersionWarnings() []string
  • func (m *ClusterInfo) GetVersionWarningsOk() bool
  • func (m *ClusterInfo) Marshal() (dAtA []byte, err error)
  • func (x *ClusterInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error
  • func (m *ClusterInfo) MarshalTo(dAtA []byte) (int, error)
  • func (m *ClusterInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ClusterInfo) ProtoMessage()
  • func (m *ClusterInfo) Reset()
  • func (m *ClusterInfo) Size() (n int)
  • func (m *ClusterInfo) String() string
  • func (m *ClusterInfo) Unmarshal(dAtA []byte) error
  • func (m *ClusterInfo) XXX_DiscardUnknown()
  • func (m *ClusterInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ClusterInfo) XXX_Merge(src proto.Message)
  • func (m *ClusterInfo) XXX_Size() int
  • func (m *ClusterInfo) XXX_Unmarshal(b []byte) error
• type InspectClusterRequest
  • func (*InspectClusterRequest) Descriptor() ([]byte, []int)
  • func (m *InspectClusterRequest) GetClientVersion() *versionpb.Version
  • func (m *InspectClusterRequest) Marshal() (dAtA []byte, err error)
  • func (x *InspectClusterRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
  • func (m *InspectClusterRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *InspectClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*InspectClusterRequest) ProtoMessage()
  • func (m *InspectClusterRequest) Reset()
  • func (m *InspectClusterRequest) Size() (n int)
  • func (m *InspectClusterRequest) String() string
  • func (m *InspectClusterRequest) Unmarshal(dAtA []byte) error
  • func (m *InspectClusterRequest) XXX_DiscardUnknown()
  • func (m *InspectClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *InspectClusterRequest) XXX_Merge(src proto.Message)
  • func (m *InspectClusterRequest) XXX_Size() int
  • func (m *InspectClusterRequest) XXX_Unmarshal(b []byte) error
• type UnimplementedAPIServer
  • func (*UnimplementedAPIServer) InspectCluster(ctx context.Context, req *InspectClusterRequest) (*ClusterInfo, error)

Variables

var (
	ErrInvalidLengthAdmin        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAdmin          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAdmin = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterAPIServer

func RegisterAPIServer(s *grpc.Server, srv APIServer)

Types

type APIClient

type APIClient interface {
	InspectCluster(ctx context.Context, in *InspectClusterRequest, opts ...grpc.CallOption) (*ClusterInfo, error)
}

APIClient is the client API for API service.

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

func NewAPIClient

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer

type APIServer interface {
	InspectCluster(context.Context, *InspectClusterRequest) (*ClusterInfo, error)
}

APIServer is the server API for API service.

type ClusterInfo

type ClusterInfo struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DeploymentID         string   `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	VersionWarningsOk    bool     `protobuf:"varint,3,opt,name=version_warnings_ok,json=versionWarningsOk,proto3" json:"version_warnings_ok,omitempty"`
	VersionWarnings      []string `protobuf:"bytes,4,rep,name=version_warnings,json=versionWarnings,proto3" json:"version_warnings,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClusterInfo) Descriptor

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

func (*ClusterInfo) GetDeploymentID

func (m *ClusterInfo) GetDeploymentID() string

func (*ClusterInfo) GetID

func (m *ClusterInfo) GetID() string

func (*ClusterInfo) GetVersionWarnings

func (m *ClusterInfo) GetVersionWarnings() []string

func (*ClusterInfo) GetVersionWarningsOk

func (m *ClusterInfo) GetVersionWarningsOk() bool

func (*ClusterInfo) Marshal

func (m *ClusterInfo) Marshal() (dAtA []byte, err error)

func (*ClusterInfo) MarshalLogObject

func (x *ClusterInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ClusterInfo) MarshalTo

func (m *ClusterInfo) MarshalTo(dAtA []byte) (int, error)

func (*ClusterInfo) MarshalToSizedBuffer

func (m *ClusterInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClusterInfo) ProtoMessage

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) Reset

func (m *ClusterInfo) Reset()

func (*ClusterInfo) Size

func (m *ClusterInfo) Size() (n int)

func (*ClusterInfo) String

func (m *ClusterInfo) String() string

func (*ClusterInfo) Unmarshal

func (m *ClusterInfo) Unmarshal(dAtA []byte) error

func (*ClusterInfo) XXX_DiscardUnknown

func (m *ClusterInfo) XXX_DiscardUnknown()

func (*ClusterInfo) XXX_Marshal

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

func (*ClusterInfo) XXX_Merge

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

func (*ClusterInfo) XXX_Size

func (m *ClusterInfo) XXX_Size() int

func (*ClusterInfo) XXX_Unmarshal

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

type InspectClusterRequest

type InspectClusterRequest struct {
	ClientVersion        *versionpb.Version `protobuf:"bytes,1,opt,name=client_version,json=clientVersion,proto3" json:"client_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*InspectClusterRequest) Descriptor

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

func (*InspectClusterRequest) GetClientVersion

func (m *InspectClusterRequest) GetClientVersion() *versionpb.Version

func (*InspectClusterRequest) Marshal

func (m *InspectClusterRequest) Marshal() (dAtA []byte, err error)

func (*InspectClusterRequest) MarshalLogObject

func (x *InspectClusterRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*InspectClusterRequest) MarshalTo

func (m *InspectClusterRequest) MarshalTo(dAtA []byte) (int, error)

func (*InspectClusterRequest) MarshalToSizedBuffer

func (m *InspectClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InspectClusterRequest) ProtoMessage

func (*InspectClusterRequest) ProtoMessage()

func (*InspectClusterRequest) Reset

func (m *InspectClusterRequest) Reset()

func (*InspectClusterRequest) Size

func (m *InspectClusterRequest) Size() (n int)

func (*InspectClusterRequest) String

func (m *InspectClusterRequest) String() string

func (*InspectClusterRequest) Unmarshal

func (m *InspectClusterRequest) Unmarshal(dAtA []byte) error

func (*InspectClusterRequest) XXX_DiscardUnknown

func (m *InspectClusterRequest) XXX_DiscardUnknown()

func (*InspectClusterRequest) XXX_Marshal

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

func (*InspectClusterRequest) XXX_Merge

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

func (*InspectClusterRequest) XXX_Size

func (m *InspectClusterRequest) XXX_Size() int

func (*InspectClusterRequest) XXX_Unmarshal

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

type UnimplementedAPIServer

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) InspectCluster

func (*UnimplementedAPIServer) InspectCluster(ctx context.Context, req *InspectClusterRequest) (*ClusterInfo, error)