Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterMeshServiceServer(s grpc.ServiceRegistrar, srv MeshServiceServer)
- type Adapter
- func (*Adapter) Descriptor() ([]byte, []int)deprecated
- func (x *Adapter) GetHost() string
- func (x *Adapter) GetName() string
- func (x *Adapter) GetPort() string
- func (*Adapter) ProtoMessage()
- func (x *Adapter) ProtoReflect() protoreflect.Message
- func (x *Adapter) Reset()
- func (x *Adapter) String() string
- type ApplyRuleRequest
- func (*ApplyRuleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyRuleRequest) GetCustomBody() string
- func (x *ApplyRuleRequest) GetDeleteOp() bool
- func (x *ApplyRuleRequest) GetKubeConfigs() []string
- func (x *ApplyRuleRequest) GetNamespace() string
- func (x *ApplyRuleRequest) GetOpName() string
- func (x *ApplyRuleRequest) GetOperationId() string
- func (x *ApplyRuleRequest) GetUsername() string
- func (*ApplyRuleRequest) ProtoMessage()
- func (x *ApplyRuleRequest) ProtoReflect() protoreflect.Message
- func (x *ApplyRuleRequest) Reset()
- func (x *ApplyRuleRequest) String() string
- type ApplyRuleResponse
- func (*ApplyRuleResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyRuleResponse) GetErrorMessage() string
- func (x *ApplyRuleResponse) GetOperationId() string
- func (*ApplyRuleResponse) ProtoMessage()
- func (x *ApplyRuleResponse) ProtoReflect() protoreflect.Message
- func (x *ApplyRuleResponse) Reset()
- func (x *ApplyRuleResponse) String() string
- type ComponentInfoRequest
- type ComponentInfoResponse
- func (*ComponentInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ComponentInfoResponse) GetComponentName() string
- func (x *ComponentInfoResponse) GetComponentType() string
- func (x *ComponentInfoResponse) GetComponentVersion() string
- func (x *ComponentInfoResponse) GetGitSha() string
- func (x *ComponentInfoResponse) GetProperties() map[string]string
- func (*ComponentInfoResponse) ProtoMessage()
- func (x *ComponentInfoResponse) ProtoReflect() protoreflect.Message
- func (x *ComponentInfoResponse) Reset()
- func (x *ComponentInfoResponse) String() string
- type EventSeverity
- func (EventSeverity) Descriptor() protoreflect.EnumDescriptor
- func (x EventSeverity) Enum() *EventSeverity
- func (EventSeverity) EnumDescriptor() ([]byte, []int)deprecated
- func (x EventSeverity) Number() protoreflect.EnumNumber
- func (x EventSeverity) String() string
- func (EventSeverity) Type() protoreflect.EnumType
- type EventsRequest
- type EventsResponse
- func (*EventsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EventsResponse) GetComponent() string
- func (x *EventsResponse) GetComponentName() string
- func (x *EventsResponse) GetDetails() string
- func (x *EventsResponse) GetErrorCode() string
- func (x *EventsResponse) GetEventSeverity() EventSeverity
- func (x *EventsResponse) GetOperationId() string
- func (x *EventsResponse) GetProbableCause() string
- func (x *EventsResponse) GetSuggestedRemediation() string
- func (x *EventsResponse) GetSummary() string
- func (*EventsResponse) ProtoMessage()
- func (x *EventsResponse) ProtoReflect() protoreflect.Message
- func (x *EventsResponse) Reset()
- func (x *EventsResponse) String() string
- type MeshNameRequest
- type MeshNameResponse
- type MeshServiceClient
- type MeshServiceServer
- type MeshService_StreamEventsClient
- type MeshService_StreamEventsServer
- type MeshVersionsRequest
- type MeshVersionsResponse
- func (*MeshVersionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MeshVersionsResponse) GetVersion() []string
- func (*MeshVersionsResponse) ProtoMessage()
- func (x *MeshVersionsResponse) ProtoReflect() protoreflect.Message
- func (x *MeshVersionsResponse) Reset()
- func (x *MeshVersionsResponse) String() string
- type OpCategory
- type PingRequest
- type PingResponse
- type ProcessOAMRequest
- func (*ProcessOAMRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessOAMRequest) GetDeleteOp() bool
- func (x *ProcessOAMRequest) GetKubeConfigs() []string
- func (x *ProcessOAMRequest) GetOamComps() []string
- func (x *ProcessOAMRequest) GetOamConfig() string
- func (x *ProcessOAMRequest) GetUsername() string
- func (*ProcessOAMRequest) ProtoMessage()
- func (x *ProcessOAMRequest) ProtoReflect() protoreflect.Message
- func (x *ProcessOAMRequest) Reset()
- func (x *ProcessOAMRequest) String() string
- type ProcessOAMResponse
- func (*ProcessOAMResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessOAMResponse) GetMessage() string
- func (*ProcessOAMResponse) ProtoMessage()
- func (x *ProcessOAMResponse) ProtoReflect() protoreflect.Message
- func (x *ProcessOAMResponse) Reset()
- func (x *ProcessOAMResponse) String() string
- type SupportedOperation
- func (*SupportedOperation) Descriptor() ([]byte, []int)deprecated
- func (x *SupportedOperation) GetCategory() OpCategory
- func (x *SupportedOperation) GetKey() string
- func (x *SupportedOperation) GetValue() string
- func (*SupportedOperation) ProtoMessage()
- func (x *SupportedOperation) ProtoReflect() protoreflect.Message
- func (x *SupportedOperation) Reset()
- func (x *SupportedOperation) String() string
- type SupportedOperationsRequest
- type SupportedOperationsResponse
- func (*SupportedOperationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SupportedOperationsResponse) GetErrorMessage() string
- func (x *SupportedOperationsResponse) GetSupportedOps() []*SupportedOperation
- func (*SupportedOperationsResponse) ProtoMessage()
- func (x *SupportedOperationsResponse) ProtoReflect() protoreflect.Message
- func (x *SupportedOperationsResponse) Reset()
- func (x *SupportedOperationsResponse) String() string
- type UnimplementedMeshServiceServer
- func (UnimplementedMeshServiceServer) ApplyOperation(context.Context, *ApplyRuleRequest) (*ApplyRuleResponse, error)
- func (UnimplementedMeshServiceServer) ComponentInfo(context.Context, *ComponentInfoRequest) (*ComponentInfoResponse, error)
- func (UnimplementedMeshServiceServer) MeshName(context.Context, *MeshNameRequest) (*MeshNameResponse, error)
- func (UnimplementedMeshServiceServer) MeshVersions(context.Context, *MeshVersionsRequest) (*MeshVersionsResponse, error)
- func (UnimplementedMeshServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
- func (UnimplementedMeshServiceServer) ProcessOAM(context.Context, *ProcessOAMRequest) (*ProcessOAMResponse, error)
- func (UnimplementedMeshServiceServer) StreamEvents(*EventsRequest, MeshService_StreamEventsServer) error
- func (UnimplementedMeshServiceServer) SupportedOperations(context.Context, *SupportedOperationsRequest) (*SupportedOperationsResponse, error)
- type UnsafeMeshServiceServer
Constants ¶
const ( MeshService_MeshName_FullMethodName = "/meshes.MeshService/MeshName" MeshService_MeshVersions_FullMethodName = "/meshes.MeshService/MeshVersions" MeshService_ApplyOperation_FullMethodName = "/meshes.MeshService/ApplyOperation" MeshService_SupportedOperations_FullMethodName = "/meshes.MeshService/SupportedOperations" MeshService_StreamEvents_FullMethodName = "/meshes.MeshService/StreamEvents" MeshService_ProcessOAM_FullMethodName = "/meshes.MeshService/ProcessOAM" MeshService_ComponentInfo_FullMethodName = "/meshes.MeshService/ComponentInfo" MeshService_Ping_FullMethodName = "/meshes.MeshService/Ping" )
Variables ¶
var ( OpCategory_name = map[int32]string{ 0: "INSTALL", 1: "SAMPLE_APPLICATION", 2: "CONFIGURE", 3: "VALIDATE", 4: "CUSTOM", } OpCategory_value = map[string]int32{ "INSTALL": 0, "SAMPLE_APPLICATION": 1, "CONFIGURE": 2, "VALIDATE": 3, "CUSTOM": 4, } )
Enum value maps for OpCategory.
var ( EventSeverity_name = map[int32]string{ 0: "INFO", 1: "WARN", 2: "ERROR", } EventSeverity_value = map[string]int32{ "INFO": 0, "WARN": 1, "ERROR": 2, } )
Enum value maps for EventSeverity.
var File_meshops_proto protoreflect.FileDescriptor
var MeshService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "meshes.MeshService", HandlerType: (*MeshServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "MeshName", Handler: _MeshService_MeshName_Handler, }, { MethodName: "MeshVersions", Handler: _MeshService_MeshVersions_Handler, }, { MethodName: "ApplyOperation", Handler: _MeshService_ApplyOperation_Handler, }, { MethodName: "SupportedOperations", Handler: _MeshService_SupportedOperations_Handler, }, { MethodName: "ProcessOAM", Handler: _MeshService_ProcessOAM_Handler, }, { MethodName: "ComponentInfo", Handler: _MeshService_ComponentInfo_Handler, }, { MethodName: "Ping", Handler: _MeshService_Ping_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamEvents", Handler: _MeshService_StreamEvents_Handler, ServerStreams: true, }, }, Metadata: "meshops.proto", }
MeshService_ServiceDesc is the grpc.ServiceDesc for MeshService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMeshServiceServer ¶
func RegisterMeshServiceServer(s grpc.ServiceRegistrar, srv MeshServiceServer)
Types ¶
type Adapter ¶
type Adapter struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` Port string `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*Adapter) ProtoReflect ¶
func (x *Adapter) ProtoReflect() protoreflect.Message
type ApplyRuleRequest ¶
type ApplyRuleRequest struct { OpName string `protobuf:"bytes,1,opt,name=op_name,json=opName,proto3" json:"op_name,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"` CustomBody string `protobuf:"bytes,4,opt,name=custom_body,json=customBody,proto3" json:"custom_body,omitempty"` DeleteOp bool `protobuf:"varint,5,opt,name=delete_op,json=deleteOp,proto3" json:"delete_op,omitempty"` OperationId string `protobuf:"bytes,6,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` KubeConfigs []string `protobuf:"bytes,7,rep,name=kube_configs,json=kubeConfigs,proto3" json:"kube_configs,omitempty"` // contains filtered or unexported fields }
func (*ApplyRuleRequest) Descriptor
deprecated
func (*ApplyRuleRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApplyRuleRequest.ProtoReflect.Descriptor instead.
func (*ApplyRuleRequest) GetCustomBody ¶
func (x *ApplyRuleRequest) GetCustomBody() string
func (*ApplyRuleRequest) GetDeleteOp ¶
func (x *ApplyRuleRequest) GetDeleteOp() bool
func (*ApplyRuleRequest) GetKubeConfigs ¶
func (x *ApplyRuleRequest) GetKubeConfigs() []string
func (*ApplyRuleRequest) GetNamespace ¶
func (x *ApplyRuleRequest) GetNamespace() string
func (*ApplyRuleRequest) GetOpName ¶
func (x *ApplyRuleRequest) GetOpName() string
func (*ApplyRuleRequest) GetOperationId ¶
func (x *ApplyRuleRequest) GetOperationId() string
func (*ApplyRuleRequest) GetUsername ¶
func (x *ApplyRuleRequest) GetUsername() string
func (*ApplyRuleRequest) ProtoMessage ¶
func (*ApplyRuleRequest) ProtoMessage()
func (*ApplyRuleRequest) ProtoReflect ¶
func (x *ApplyRuleRequest) ProtoReflect() protoreflect.Message
func (*ApplyRuleRequest) Reset ¶
func (x *ApplyRuleRequest) Reset()
func (*ApplyRuleRequest) String ¶
func (x *ApplyRuleRequest) String() string
type ApplyRuleResponse ¶
type ApplyRuleResponse struct { ErrorMessage string `protobuf:"bytes,1,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` OperationId string `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` // contains filtered or unexported fields }
func (*ApplyRuleResponse) Descriptor
deprecated
func (*ApplyRuleResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApplyRuleResponse.ProtoReflect.Descriptor instead.
func (*ApplyRuleResponse) GetErrorMessage ¶
func (x *ApplyRuleResponse) GetErrorMessage() string
func (*ApplyRuleResponse) GetOperationId ¶
func (x *ApplyRuleResponse) GetOperationId() string
func (*ApplyRuleResponse) ProtoMessage ¶
func (*ApplyRuleResponse) ProtoMessage()
func (*ApplyRuleResponse) ProtoReflect ¶
func (x *ApplyRuleResponse) ProtoReflect() protoreflect.Message
func (*ApplyRuleResponse) Reset ¶
func (x *ApplyRuleResponse) Reset()
func (*ApplyRuleResponse) String ¶
func (x *ApplyRuleResponse) String() string
type ComponentInfoRequest ¶
type ComponentInfoRequest struct {
// contains filtered or unexported fields
}
func (*ComponentInfoRequest) Descriptor
deprecated
func (*ComponentInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use ComponentInfoRequest.ProtoReflect.Descriptor instead.
func (*ComponentInfoRequest) ProtoMessage ¶
func (*ComponentInfoRequest) ProtoMessage()
func (*ComponentInfoRequest) ProtoReflect ¶
func (x *ComponentInfoRequest) ProtoReflect() protoreflect.Message
func (*ComponentInfoRequest) Reset ¶
func (x *ComponentInfoRequest) Reset()
func (*ComponentInfoRequest) String ¶
func (x *ComponentInfoRequest) String() string
type ComponentInfoResponse ¶
type ComponentInfoResponse struct { ComponentType string `protobuf:"bytes,1,opt,name=component_type,json=componentType,proto3" json:"component_type,omitempty"` ComponentName string `protobuf:"bytes,2,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"` ComponentVersion string `protobuf:"bytes,3,opt,name=component_version,json=componentVersion,proto3" json:"component_version,omitempty"` GitSha string `protobuf:"bytes,4,opt,name=git_sha,json=gitSha,proto3" json:"git_sha,omitempty"` Properties map[string]string `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ComponentInfoResponse) Descriptor
deprecated
func (*ComponentInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use ComponentInfoResponse.ProtoReflect.Descriptor instead.
func (*ComponentInfoResponse) GetComponentName ¶
func (x *ComponentInfoResponse) GetComponentName() string
func (*ComponentInfoResponse) GetComponentType ¶
func (x *ComponentInfoResponse) GetComponentType() string
func (*ComponentInfoResponse) GetComponentVersion ¶
func (x *ComponentInfoResponse) GetComponentVersion() string
func (*ComponentInfoResponse) GetGitSha ¶
func (x *ComponentInfoResponse) GetGitSha() string
func (*ComponentInfoResponse) GetProperties ¶
func (x *ComponentInfoResponse) GetProperties() map[string]string
func (*ComponentInfoResponse) ProtoMessage ¶
func (*ComponentInfoResponse) ProtoMessage()
func (*ComponentInfoResponse) ProtoReflect ¶
func (x *ComponentInfoResponse) ProtoReflect() protoreflect.Message
func (*ComponentInfoResponse) Reset ¶
func (x *ComponentInfoResponse) Reset()
func (*ComponentInfoResponse) String ¶
func (x *ComponentInfoResponse) String() string
type EventSeverity ¶
type EventSeverity int32
const ( EventSeverity_INFO EventSeverity = 0 EventSeverity_WARN EventSeverity = 1 EventSeverity_ERROR EventSeverity = 2 )
func (EventSeverity) Descriptor ¶
func (EventSeverity) Descriptor() protoreflect.EnumDescriptor
func (EventSeverity) Enum ¶
func (x EventSeverity) Enum() *EventSeverity
func (EventSeverity) EnumDescriptor
deprecated
func (EventSeverity) EnumDescriptor() ([]byte, []int)
Deprecated: Use EventSeverity.Descriptor instead.
func (EventSeverity) Number ¶
func (x EventSeverity) Number() protoreflect.EnumNumber
func (EventSeverity) String ¶
func (x EventSeverity) String() string
func (EventSeverity) Type ¶
func (EventSeverity) Type() protoreflect.EnumType
type EventsRequest ¶
type EventsRequest struct {
// contains filtered or unexported fields
}
func (*EventsRequest) Descriptor
deprecated
func (*EventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use EventsRequest.ProtoReflect.Descriptor instead.
func (*EventsRequest) ProtoMessage ¶
func (*EventsRequest) ProtoMessage()
func (*EventsRequest) ProtoReflect ¶
func (x *EventsRequest) ProtoReflect() protoreflect.Message
func (*EventsRequest) Reset ¶
func (x *EventsRequest) Reset()
func (*EventsRequest) String ¶
func (x *EventsRequest) String() string
type EventsResponse ¶
type EventsResponse struct { EventSeverity EventSeverity `` /* 127-byte string literal not displayed */ Summary string `protobuf:"bytes,2,opt,name=summary,proto3" json:"summary,omitempty"` Details string `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"` OperationId string `protobuf:"bytes,4,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` ProbableCause string `protobuf:"bytes,5,opt,name=probable_cause,json=probableCause,proto3" json:"probable_cause,omitempty"` SuggestedRemediation string `protobuf:"bytes,6,opt,name=suggested_remediation,json=suggestedRemediation,proto3" json:"suggested_remediation,omitempty"` ErrorCode string `protobuf:"bytes,7,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"` Component string `protobuf:"bytes,8,opt,name=component,proto3" json:"component,omitempty"` ComponentName string `protobuf:"bytes,9,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"` // contains filtered or unexported fields }
func (*EventsResponse) Descriptor
deprecated
func (*EventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use EventsResponse.ProtoReflect.Descriptor instead.
func (*EventsResponse) GetComponent ¶
func (x *EventsResponse) GetComponent() string
func (*EventsResponse) GetComponentName ¶
func (x *EventsResponse) GetComponentName() string
func (*EventsResponse) GetDetails ¶
func (x *EventsResponse) GetDetails() string
func (*EventsResponse) GetErrorCode ¶
func (x *EventsResponse) GetErrorCode() string
func (*EventsResponse) GetEventSeverity ¶
func (x *EventsResponse) GetEventSeverity() EventSeverity
func (*EventsResponse) GetOperationId ¶
func (x *EventsResponse) GetOperationId() string
func (*EventsResponse) GetProbableCause ¶
func (x *EventsResponse) GetProbableCause() string
func (*EventsResponse) GetSuggestedRemediation ¶
func (x *EventsResponse) GetSuggestedRemediation() string
func (*EventsResponse) GetSummary ¶
func (x *EventsResponse) GetSummary() string
func (*EventsResponse) ProtoMessage ¶
func (*EventsResponse) ProtoMessage()
func (*EventsResponse) ProtoReflect ¶
func (x *EventsResponse) ProtoReflect() protoreflect.Message
func (*EventsResponse) Reset ¶
func (x *EventsResponse) Reset()
func (*EventsResponse) String ¶
func (x *EventsResponse) String() string
type MeshNameRequest ¶
type MeshNameRequest struct {
// contains filtered or unexported fields
}
func (*MeshNameRequest) Descriptor
deprecated
func (*MeshNameRequest) Descriptor() ([]byte, []int)
Deprecated: Use MeshNameRequest.ProtoReflect.Descriptor instead.
func (*MeshNameRequest) ProtoMessage ¶
func (*MeshNameRequest) ProtoMessage()
func (*MeshNameRequest) ProtoReflect ¶
func (x *MeshNameRequest) ProtoReflect() protoreflect.Message
func (*MeshNameRequest) Reset ¶
func (x *MeshNameRequest) Reset()
func (*MeshNameRequest) String ¶
func (x *MeshNameRequest) String() string
type MeshNameResponse ¶
type MeshNameResponse struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*MeshNameResponse) Descriptor
deprecated
func (*MeshNameResponse) Descriptor() ([]byte, []int)
Deprecated: Use MeshNameResponse.ProtoReflect.Descriptor instead.
func (*MeshNameResponse) GetName ¶
func (x *MeshNameResponse) GetName() string
func (*MeshNameResponse) ProtoMessage ¶
func (*MeshNameResponse) ProtoMessage()
func (*MeshNameResponse) ProtoReflect ¶
func (x *MeshNameResponse) ProtoReflect() protoreflect.Message
func (*MeshNameResponse) Reset ¶
func (x *MeshNameResponse) Reset()
func (*MeshNameResponse) String ¶
func (x *MeshNameResponse) String() string
type MeshServiceClient ¶
type MeshServiceClient interface { MeshName(ctx context.Context, in *MeshNameRequest, opts ...grpc.CallOption) (*MeshNameResponse, error) MeshVersions(ctx context.Context, in *MeshVersionsRequest, opts ...grpc.CallOption) (*MeshVersionsResponse, error) ApplyOperation(ctx context.Context, in *ApplyRuleRequest, opts ...grpc.CallOption) (*ApplyRuleResponse, error) SupportedOperations(ctx context.Context, in *SupportedOperationsRequest, opts ...grpc.CallOption) (*SupportedOperationsResponse, error) StreamEvents(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (MeshService_StreamEventsClient, error) ProcessOAM(ctx context.Context, in *ProcessOAMRequest, opts ...grpc.CallOption) (*ProcessOAMResponse, error) ComponentInfo(ctx context.Context, in *ComponentInfoRequest, opts ...grpc.CallOption) (*ComponentInfoResponse, error) Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) }
MeshServiceClient is the client API for MeshService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewMeshServiceClient ¶
func NewMeshServiceClient(cc grpc.ClientConnInterface) MeshServiceClient
type MeshServiceServer ¶
type MeshServiceServer interface { MeshName(context.Context, *MeshNameRequest) (*MeshNameResponse, error) MeshVersions(context.Context, *MeshVersionsRequest) (*MeshVersionsResponse, error) ApplyOperation(context.Context, *ApplyRuleRequest) (*ApplyRuleResponse, error) SupportedOperations(context.Context, *SupportedOperationsRequest) (*SupportedOperationsResponse, error) StreamEvents(*EventsRequest, MeshService_StreamEventsServer) error ProcessOAM(context.Context, *ProcessOAMRequest) (*ProcessOAMResponse, error) ComponentInfo(context.Context, *ComponentInfoRequest) (*ComponentInfoResponse, error) Ping(context.Context, *PingRequest) (*PingResponse, error) // contains filtered or unexported methods }
MeshServiceServer is the server API for MeshService service. All implementations must embed UnimplementedMeshServiceServer for forward compatibility
type MeshService_StreamEventsClient ¶
type MeshService_StreamEventsClient interface { Recv() (*EventsResponse, error) grpc.ClientStream }
type MeshService_StreamEventsServer ¶
type MeshService_StreamEventsServer interface { Send(*EventsResponse) error grpc.ServerStream }
type MeshVersionsRequest ¶
type MeshVersionsRequest struct {
// contains filtered or unexported fields
}
func (*MeshVersionsRequest) Descriptor
deprecated
func (*MeshVersionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use MeshVersionsRequest.ProtoReflect.Descriptor instead.
func (*MeshVersionsRequest) ProtoMessage ¶
func (*MeshVersionsRequest) ProtoMessage()
func (*MeshVersionsRequest) ProtoReflect ¶
func (x *MeshVersionsRequest) ProtoReflect() protoreflect.Message
func (*MeshVersionsRequest) Reset ¶
func (x *MeshVersionsRequest) Reset()
func (*MeshVersionsRequest) String ¶
func (x *MeshVersionsRequest) String() string
type MeshVersionsResponse ¶
type MeshVersionsResponse struct { Version []string `protobuf:"bytes,1,rep,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*MeshVersionsResponse) Descriptor
deprecated
func (*MeshVersionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use MeshVersionsResponse.ProtoReflect.Descriptor instead.
func (*MeshVersionsResponse) GetVersion ¶
func (x *MeshVersionsResponse) GetVersion() []string
func (*MeshVersionsResponse) ProtoMessage ¶
func (*MeshVersionsResponse) ProtoMessage()
func (*MeshVersionsResponse) ProtoReflect ¶
func (x *MeshVersionsResponse) ProtoReflect() protoreflect.Message
func (*MeshVersionsResponse) Reset ¶
func (x *MeshVersionsResponse) Reset()
func (*MeshVersionsResponse) String ¶
func (x *MeshVersionsResponse) String() string
type OpCategory ¶
type OpCategory int32
const ( OpCategory_INSTALL OpCategory = 0 OpCategory_SAMPLE_APPLICATION OpCategory = 1 OpCategory_CONFIGURE OpCategory = 2 OpCategory_VALIDATE OpCategory = 3 OpCategory_CUSTOM OpCategory = 4 )
func (OpCategory) Descriptor ¶
func (OpCategory) Descriptor() protoreflect.EnumDescriptor
func (OpCategory) Enum ¶
func (x OpCategory) Enum() *OpCategory
func (OpCategory) EnumDescriptor
deprecated
func (OpCategory) EnumDescriptor() ([]byte, []int)
Deprecated: Use OpCategory.Descriptor instead.
func (OpCategory) Number ¶
func (x OpCategory) Number() protoreflect.EnumNumber
func (OpCategory) String ¶
func (x OpCategory) String() string
func (OpCategory) Type ¶
func (OpCategory) Type() protoreflect.EnumType
type PingRequest ¶
type PingRequest struct { Adapter *Adapter `protobuf:"bytes,1,opt,name=adapter,proto3" json:"adapter,omitempty"` // contains filtered or unexported fields }
func (*PingRequest) Descriptor
deprecated
func (*PingRequest) Descriptor() ([]byte, []int)
Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.
func (*PingRequest) GetAdapter ¶
func (x *PingRequest) GetAdapter() *Adapter
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) ProtoReflect ¶
func (x *PingRequest) ProtoReflect() protoreflect.Message
func (*PingRequest) Reset ¶
func (x *PingRequest) Reset()
func (*PingRequest) String ¶
func (x *PingRequest) String() string
type PingResponse ¶
type PingResponse struct { IsHealthy bool `protobuf:"varint,1,opt,name=is_healthy,json=isHealthy,proto3" json:"is_healthy,omitempty"` // contains filtered or unexported fields }
func (*PingResponse) Descriptor
deprecated
func (*PingResponse) Descriptor() ([]byte, []int)
Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.
func (*PingResponse) GetIsHealthy ¶
func (x *PingResponse) GetIsHealthy() bool
func (*PingResponse) ProtoMessage ¶
func (*PingResponse) ProtoMessage()
func (*PingResponse) ProtoReflect ¶
func (x *PingResponse) ProtoReflect() protoreflect.Message
func (*PingResponse) Reset ¶
func (x *PingResponse) Reset()
func (*PingResponse) String ¶
func (x *PingResponse) String() string
type ProcessOAMRequest ¶
type ProcessOAMRequest struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` DeleteOp bool `protobuf:"varint,2,opt,name=delete_op,json=deleteOp,proto3" json:"delete_op,omitempty"` OamComps []string `protobuf:"bytes,3,rep,name=oam_comps,json=oamComps,proto3" json:"oam_comps,omitempty"` OamConfig string `protobuf:"bytes,4,opt,name=oam_config,json=oamConfig,proto3" json:"oam_config,omitempty"` KubeConfigs []string `protobuf:"bytes,5,rep,name=kube_configs,json=kubeConfigs,proto3" json:"kube_configs,omitempty"` // contains filtered or unexported fields }
func (*ProcessOAMRequest) Descriptor
deprecated
func (*ProcessOAMRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProcessOAMRequest.ProtoReflect.Descriptor instead.
func (*ProcessOAMRequest) GetDeleteOp ¶
func (x *ProcessOAMRequest) GetDeleteOp() bool
func (*ProcessOAMRequest) GetKubeConfigs ¶
func (x *ProcessOAMRequest) GetKubeConfigs() []string
func (*ProcessOAMRequest) GetOamComps ¶
func (x *ProcessOAMRequest) GetOamComps() []string
func (*ProcessOAMRequest) GetOamConfig ¶
func (x *ProcessOAMRequest) GetOamConfig() string
func (*ProcessOAMRequest) GetUsername ¶
func (x *ProcessOAMRequest) GetUsername() string
func (*ProcessOAMRequest) ProtoMessage ¶
func (*ProcessOAMRequest) ProtoMessage()
func (*ProcessOAMRequest) ProtoReflect ¶
func (x *ProcessOAMRequest) ProtoReflect() protoreflect.Message
func (*ProcessOAMRequest) Reset ¶
func (x *ProcessOAMRequest) Reset()
func (*ProcessOAMRequest) String ¶
func (x *ProcessOAMRequest) String() string
type ProcessOAMResponse ¶
type ProcessOAMResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*ProcessOAMResponse) Descriptor
deprecated
func (*ProcessOAMResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProcessOAMResponse.ProtoReflect.Descriptor instead.
func (*ProcessOAMResponse) GetMessage ¶
func (x *ProcessOAMResponse) GetMessage() string
func (*ProcessOAMResponse) ProtoMessage ¶
func (*ProcessOAMResponse) ProtoMessage()
func (*ProcessOAMResponse) ProtoReflect ¶
func (x *ProcessOAMResponse) ProtoReflect() protoreflect.Message
func (*ProcessOAMResponse) Reset ¶
func (x *ProcessOAMResponse) Reset()
func (*ProcessOAMResponse) String ¶
func (x *ProcessOAMResponse) String() string
type SupportedOperation ¶
type SupportedOperation struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` Category OpCategory `protobuf:"varint,3,opt,name=category,proto3,enum=meshes.OpCategory" json:"category,omitempty"` // contains filtered or unexported fields }
func (*SupportedOperation) Descriptor
deprecated
func (*SupportedOperation) Descriptor() ([]byte, []int)
Deprecated: Use SupportedOperation.ProtoReflect.Descriptor instead.
func (*SupportedOperation) GetCategory ¶
func (x *SupportedOperation) GetCategory() OpCategory
func (*SupportedOperation) GetKey ¶
func (x *SupportedOperation) GetKey() string
func (*SupportedOperation) GetValue ¶
func (x *SupportedOperation) GetValue() string
func (*SupportedOperation) ProtoMessage ¶
func (*SupportedOperation) ProtoMessage()
func (*SupportedOperation) ProtoReflect ¶
func (x *SupportedOperation) ProtoReflect() protoreflect.Message
func (*SupportedOperation) Reset ¶
func (x *SupportedOperation) Reset()
func (*SupportedOperation) String ¶
func (x *SupportedOperation) String() string
type SupportedOperationsRequest ¶
type SupportedOperationsRequest struct {
// contains filtered or unexported fields
}
func (*SupportedOperationsRequest) Descriptor
deprecated
func (*SupportedOperationsRequest) Descriptor() ([]byte, []int)
Deprecated: Use SupportedOperationsRequest.ProtoReflect.Descriptor instead.
func (*SupportedOperationsRequest) ProtoMessage ¶
func (*SupportedOperationsRequest) ProtoMessage()
func (*SupportedOperationsRequest) ProtoReflect ¶
func (x *SupportedOperationsRequest) ProtoReflect() protoreflect.Message
func (*SupportedOperationsRequest) Reset ¶
func (x *SupportedOperationsRequest) Reset()
func (*SupportedOperationsRequest) String ¶
func (x *SupportedOperationsRequest) String() string
type SupportedOperationsResponse ¶
type SupportedOperationsResponse struct { SupportedOps []*SupportedOperation `protobuf:"bytes,1,rep,name=supported_ops,json=supportedOps,proto3" json:"supported_ops,omitempty"` ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` // contains filtered or unexported fields }
func (*SupportedOperationsResponse) Descriptor
deprecated
func (*SupportedOperationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use SupportedOperationsResponse.ProtoReflect.Descriptor instead.
func (*SupportedOperationsResponse) GetErrorMessage ¶
func (x *SupportedOperationsResponse) GetErrorMessage() string
func (*SupportedOperationsResponse) GetSupportedOps ¶
func (x *SupportedOperationsResponse) GetSupportedOps() []*SupportedOperation
func (*SupportedOperationsResponse) ProtoMessage ¶
func (*SupportedOperationsResponse) ProtoMessage()
func (*SupportedOperationsResponse) ProtoReflect ¶
func (x *SupportedOperationsResponse) ProtoReflect() protoreflect.Message
func (*SupportedOperationsResponse) Reset ¶
func (x *SupportedOperationsResponse) Reset()
func (*SupportedOperationsResponse) String ¶
func (x *SupportedOperationsResponse) String() string
type UnimplementedMeshServiceServer ¶
type UnimplementedMeshServiceServer struct { }
UnimplementedMeshServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedMeshServiceServer) ApplyOperation ¶
func (UnimplementedMeshServiceServer) ApplyOperation(context.Context, *ApplyRuleRequest) (*ApplyRuleResponse, error)
func (UnimplementedMeshServiceServer) ComponentInfo ¶
func (UnimplementedMeshServiceServer) ComponentInfo(context.Context, *ComponentInfoRequest) (*ComponentInfoResponse, error)
func (UnimplementedMeshServiceServer) MeshName ¶
func (UnimplementedMeshServiceServer) MeshName(context.Context, *MeshNameRequest) (*MeshNameResponse, error)
func (UnimplementedMeshServiceServer) MeshVersions ¶
func (UnimplementedMeshServiceServer) MeshVersions(context.Context, *MeshVersionsRequest) (*MeshVersionsResponse, error)
func (UnimplementedMeshServiceServer) Ping ¶
func (UnimplementedMeshServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
func (UnimplementedMeshServiceServer) ProcessOAM ¶
func (UnimplementedMeshServiceServer) ProcessOAM(context.Context, *ProcessOAMRequest) (*ProcessOAMResponse, error)
func (UnimplementedMeshServiceServer) StreamEvents ¶
func (UnimplementedMeshServiceServer) StreamEvents(*EventsRequest, MeshService_StreamEventsServer) error
func (UnimplementedMeshServiceServer) SupportedOperations ¶
func (UnimplementedMeshServiceServer) SupportedOperations(context.Context, *SupportedOperationsRequest) (*SupportedOperationsResponse, error)
type UnsafeMeshServiceServer ¶
type UnsafeMeshServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMeshServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MeshServiceServer will result in compilation errors.