Documentation ¶
Index ¶
- Variables
- func RegisterMeshServiceServer(s grpc.ServiceRegistrar, srv MeshServiceServer)
- 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) GetError() 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) GetGitSha() string
- func (x *ComponentInfoResponse) GetName() string
- func (x *ComponentInfoResponse) GetProperties() map[string]string
- func (x *ComponentInfoResponse) GetType() string
- func (x *ComponentInfoResponse) GetVersion() string
- func (*ComponentInfoResponse) ProtoMessage()
- func (x *ComponentInfoResponse) ProtoReflect() protoreflect.Message
- func (x *ComponentInfoResponse) Reset()
- func (x *ComponentInfoResponse) String() string
- type EventType
- 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) GetEventType() EventType
- 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 MeshClient
- 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 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) GetError() string
- func (x *SupportedOperationsResponse) GetOps() []*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) ProcessOAM(context.Context, *ProcessOAMRequest) (*ProcessOAMResponse, error)
- func (UnimplementedMeshServiceServer) StreamEvents(*EventsRequest, MeshService_StreamEventsServer) error
- func (UnimplementedMeshServiceServer) SupportedOperations(context.Context, *SupportedOperationsRequest) (*SupportedOperationsResponse, error)
- type UnsafeMeshServiceServer
Constants ¶
This section is empty.
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 ( EventType_name = map[int32]string{ 0: "INFO", 1: "WARN", 2: "ERROR", } EventType_value = map[string]int32{ "INFO": 0, "WARN": 1, "ERROR": 2, } )
Enum value maps for EventType.
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, }, }, 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 ApplyRuleRequest ¶
type ApplyRuleRequest struct { OpName string `protobuf:"bytes,1,opt,name=opName,proto3" json:"opName,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 { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,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) GetError ¶
func (x *ApplyRuleResponse) GetError() 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
}
The idea is that all components' gRPC endpoint would provide a ComponentInfo function.
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 { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` // the component type, e.g. "adapter", as all components might provide a ComponentInfo function Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // the component name, e.g. "kuma" Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` // the component version, e.g. v0.1.5 GitSha string `protobuf:"bytes,4,opt,name=git_sha,json=gitSha,proto3" json:"git_sha,omitempty"` // the git commit sha Properties map[string]string `` // any other properties of interest /* 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) GetGitSha ¶
func (x *ComponentInfoResponse) GetGitSha() string
func (*ComponentInfoResponse) GetName ¶
func (x *ComponentInfoResponse) GetName() string
func (*ComponentInfoResponse) GetProperties ¶
func (x *ComponentInfoResponse) GetProperties() map[string]string
func (*ComponentInfoResponse) GetType ¶
func (x *ComponentInfoResponse) GetType() string
func (*ComponentInfoResponse) GetVersion ¶
func (x *ComponentInfoResponse) GetVersion() 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 EventType ¶
type EventType int32
func (EventType) Descriptor ¶
func (EventType) Descriptor() protoreflect.EnumDescriptor
func (EventType) EnumDescriptor
deprecated
func (EventType) Number ¶
func (x EventType) Number() protoreflect.EnumNumber
func (EventType) Type ¶
func (EventType) 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 { EventType EventType `protobuf:"varint,1,opt,name=event_type,json=eventType,proto3,enum=meshes.EventType" json:"event_type,omitempty"` 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) GetEventType ¶
func (x *EventsResponse) GetEventType() EventType
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 MeshClient ¶
type MeshClient struct { MClient MeshServiceClient // contains filtered or unexported fields }
MeshClient represents a gRPC adapter client
func CreateClient ¶
func CreateClient(ctx context.Context, meshLocationURL string) (*MeshClient, error)
CreateClient creates a MeshClient for the given params
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) }
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) // 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 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,7,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 { Ops []*SupportedOperation `protobuf:"bytes,1,rep,name=ops,proto3" json:"ops,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*SupportedOperationsResponse) Descriptor
deprecated
func (*SupportedOperationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use SupportedOperationsResponse.ProtoReflect.Descriptor instead.
func (*SupportedOperationsResponse) GetError ¶
func (x *SupportedOperationsResponse) GetError() string
func (*SupportedOperationsResponse) GetOps ¶
func (x *SupportedOperationsResponse) GetOps() []*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) 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.