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) 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 CreateMeshInstanceRequest
- func (*CreateMeshInstanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateMeshInstanceRequest) GetContextName() string
- func (x *CreateMeshInstanceRequest) GetK8SConfig() []byte
- func (*CreateMeshInstanceRequest) ProtoMessage()
- func (x *CreateMeshInstanceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateMeshInstanceRequest) Reset()
- func (x *CreateMeshInstanceRequest) String() string
- type CreateMeshInstanceResponse
- type EventType
- type EventsRequest
- type EventsResponse
- func (*EventsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EventsResponse) GetDetails() string
- func (x *EventsResponse) GetEventType() EventType
- func (x *EventsResponse) GetOperationId() 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) 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) CreateMeshInstance(context.Context, *CreateMeshInstanceRequest) (*CreateMeshInstanceResponse, 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: "CreateMeshInstance", Handler: _MeshService_CreateMeshInstance_Handler, }, { 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 ¶ added in v0.0.4
func RegisterMeshServiceServer(s grpc.ServiceRegistrar, srv MeshServiceServer)
Types ¶
type ApplyRuleRequest ¶ added in v0.0.4
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"` // contains filtered or unexported fields }
func (*ApplyRuleRequest) Descriptor
deprecated
added in
v0.0.4
func (*ApplyRuleRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApplyRuleRequest.ProtoReflect.Descriptor instead.
func (*ApplyRuleRequest) GetCustomBody ¶ added in v0.0.4
func (x *ApplyRuleRequest) GetCustomBody() string
func (*ApplyRuleRequest) GetDeleteOp ¶ added in v0.0.4
func (x *ApplyRuleRequest) GetDeleteOp() bool
func (*ApplyRuleRequest) GetNamespace ¶ added in v0.0.4
func (x *ApplyRuleRequest) GetNamespace() string
func (*ApplyRuleRequest) GetOpName ¶ added in v0.0.4
func (x *ApplyRuleRequest) GetOpName() string
func (*ApplyRuleRequest) GetOperationId ¶ added in v0.0.6
func (x *ApplyRuleRequest) GetOperationId() string
func (*ApplyRuleRequest) GetUsername ¶ added in v0.0.4
func (x *ApplyRuleRequest) GetUsername() string
func (*ApplyRuleRequest) ProtoMessage ¶ added in v0.0.4
func (*ApplyRuleRequest) ProtoMessage()
func (*ApplyRuleRequest) ProtoReflect ¶ added in v0.5.1
func (x *ApplyRuleRequest) ProtoReflect() protoreflect.Message
func (*ApplyRuleRequest) Reset ¶ added in v0.0.4
func (x *ApplyRuleRequest) Reset()
func (*ApplyRuleRequest) String ¶ added in v0.0.4
func (x *ApplyRuleRequest) String() string
type ApplyRuleResponse ¶ added in v0.0.4
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
added in
v0.0.4
func (*ApplyRuleResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApplyRuleResponse.ProtoReflect.Descriptor instead.
func (*ApplyRuleResponse) GetError ¶ added in v0.0.4
func (x *ApplyRuleResponse) GetError() string
func (*ApplyRuleResponse) GetOperationId ¶ added in v0.0.6
func (x *ApplyRuleResponse) GetOperationId() string
func (*ApplyRuleResponse) ProtoMessage ¶ added in v0.0.4
func (*ApplyRuleResponse) ProtoMessage()
func (*ApplyRuleResponse) ProtoReflect ¶ added in v0.5.1
func (x *ApplyRuleResponse) ProtoReflect() protoreflect.Message
func (*ApplyRuleResponse) Reset ¶ added in v0.0.4
func (x *ApplyRuleResponse) Reset()
func (*ApplyRuleResponse) String ¶ added in v0.0.4
func (x *ApplyRuleResponse) String() string
type ComponentInfoRequest ¶ added in v0.5.2
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
added in
v0.5.2
func (*ComponentInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use ComponentInfoRequest.ProtoReflect.Descriptor instead.
func (*ComponentInfoRequest) ProtoMessage ¶ added in v0.5.2
func (*ComponentInfoRequest) ProtoMessage()
func (*ComponentInfoRequest) ProtoReflect ¶ added in v0.5.2
func (x *ComponentInfoRequest) ProtoReflect() protoreflect.Message
func (*ComponentInfoRequest) Reset ¶ added in v0.5.2
func (x *ComponentInfoRequest) Reset()
func (*ComponentInfoRequest) String ¶ added in v0.5.2
func (x *ComponentInfoRequest) String() string
type ComponentInfoResponse ¶ added in v0.5.2
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
added in
v0.5.2
func (*ComponentInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use ComponentInfoResponse.ProtoReflect.Descriptor instead.
func (*ComponentInfoResponse) GetGitSha ¶ added in v0.5.2
func (x *ComponentInfoResponse) GetGitSha() string
func (*ComponentInfoResponse) GetName ¶ added in v0.5.2
func (x *ComponentInfoResponse) GetName() string
func (*ComponentInfoResponse) GetProperties ¶ added in v0.5.2
func (x *ComponentInfoResponse) GetProperties() map[string]string
func (*ComponentInfoResponse) GetType ¶ added in v0.5.2
func (x *ComponentInfoResponse) GetType() string
func (*ComponentInfoResponse) GetVersion ¶ added in v0.5.2
func (x *ComponentInfoResponse) GetVersion() string
func (*ComponentInfoResponse) ProtoMessage ¶ added in v0.5.2
func (*ComponentInfoResponse) ProtoMessage()
func (*ComponentInfoResponse) ProtoReflect ¶ added in v0.5.2
func (x *ComponentInfoResponse) ProtoReflect() protoreflect.Message
func (*ComponentInfoResponse) Reset ¶ added in v0.5.2
func (x *ComponentInfoResponse) Reset()
func (*ComponentInfoResponse) String ¶ added in v0.5.2
func (x *ComponentInfoResponse) String() string
type CreateMeshInstanceRequest ¶ added in v0.0.4
type CreateMeshInstanceRequest struct { K8SConfig []byte `protobuf:"bytes,1,opt,name=k8sConfig,proto3" json:"k8sConfig,omitempty"` ContextName string `protobuf:"bytes,2,opt,name=contextName,proto3" json:"contextName,omitempty"` // contains filtered or unexported fields }
func (*CreateMeshInstanceRequest) Descriptor
deprecated
added in
v0.0.4
func (*CreateMeshInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateMeshInstanceRequest.ProtoReflect.Descriptor instead.
func (*CreateMeshInstanceRequest) GetContextName ¶ added in v0.0.4
func (x *CreateMeshInstanceRequest) GetContextName() string
func (*CreateMeshInstanceRequest) GetK8SConfig ¶ added in v0.0.4
func (x *CreateMeshInstanceRequest) GetK8SConfig() []byte
func (*CreateMeshInstanceRequest) ProtoMessage ¶ added in v0.0.4
func (*CreateMeshInstanceRequest) ProtoMessage()
func (*CreateMeshInstanceRequest) ProtoReflect ¶ added in v0.5.1
func (x *CreateMeshInstanceRequest) ProtoReflect() protoreflect.Message
func (*CreateMeshInstanceRequest) Reset ¶ added in v0.0.4
func (x *CreateMeshInstanceRequest) Reset()
func (*CreateMeshInstanceRequest) String ¶ added in v0.0.4
func (x *CreateMeshInstanceRequest) String() string
type CreateMeshInstanceResponse ¶ added in v0.0.4
type CreateMeshInstanceResponse struct {
// contains filtered or unexported fields
}
func (*CreateMeshInstanceResponse) Descriptor
deprecated
added in
v0.0.4
func (*CreateMeshInstanceResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateMeshInstanceResponse.ProtoReflect.Descriptor instead.
func (*CreateMeshInstanceResponse) ProtoMessage ¶ added in v0.0.4
func (*CreateMeshInstanceResponse) ProtoMessage()
func (*CreateMeshInstanceResponse) ProtoReflect ¶ added in v0.5.1
func (x *CreateMeshInstanceResponse) ProtoReflect() protoreflect.Message
func (*CreateMeshInstanceResponse) Reset ¶ added in v0.0.4
func (x *CreateMeshInstanceResponse) Reset()
func (*CreateMeshInstanceResponse) String ¶ added in v0.0.4
func (x *CreateMeshInstanceResponse) String() string
type EventType ¶ added in v0.0.6
type EventType int32
func (EventType) Descriptor ¶ added in v0.5.1
func (EventType) Descriptor() protoreflect.EnumDescriptor
func (EventType) EnumDescriptor
deprecated
added in
v0.0.6
func (EventType) Number ¶ added in v0.5.1
func (x EventType) Number() protoreflect.EnumNumber
func (EventType) Type ¶ added in v0.5.1
func (EventType) Type() protoreflect.EnumType
type EventsRequest ¶ added in v0.0.6
type EventsRequest struct {
// contains filtered or unexported fields
}
func (*EventsRequest) Descriptor
deprecated
added in
v0.0.6
func (*EventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use EventsRequest.ProtoReflect.Descriptor instead.
func (*EventsRequest) ProtoMessage ¶ added in v0.0.6
func (*EventsRequest) ProtoMessage()
func (*EventsRequest) ProtoReflect ¶ added in v0.5.1
func (x *EventsRequest) ProtoReflect() protoreflect.Message
func (*EventsRequest) Reset ¶ added in v0.0.6
func (x *EventsRequest) Reset()
func (*EventsRequest) String ¶ added in v0.0.6
func (x *EventsRequest) String() string
type EventsResponse ¶ added in v0.0.6
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"` // contains filtered or unexported fields }
func (*EventsResponse) Descriptor
deprecated
added in
v0.0.6
func (*EventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use EventsResponse.ProtoReflect.Descriptor instead.
func (*EventsResponse) GetDetails ¶ added in v0.0.6
func (x *EventsResponse) GetDetails() string
func (*EventsResponse) GetEventType ¶ added in v0.0.6
func (x *EventsResponse) GetEventType() EventType
func (*EventsResponse) GetOperationId ¶ added in v0.0.6
func (x *EventsResponse) GetOperationId() string
func (*EventsResponse) GetSummary ¶ added in v0.0.6
func (x *EventsResponse) GetSummary() string
func (*EventsResponse) ProtoMessage ¶ added in v0.0.6
func (*EventsResponse) ProtoMessage()
func (*EventsResponse) ProtoReflect ¶ added in v0.5.1
func (x *EventsResponse) ProtoReflect() protoreflect.Message
func (*EventsResponse) Reset ¶ added in v0.0.6
func (x *EventsResponse) Reset()
func (*EventsResponse) String ¶ added in v0.0.6
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 ¶ added in v0.0.4
func CreateClient(ctx context.Context, k8sConfigBytes []byte, contextName, meshLocationURL string) (*MeshClient, error)
CreateClient creates a MeshClient for the given params
func (*MeshClient) Close ¶ added in v0.0.4
func (m *MeshClient) Close() error
Close closes the MeshClient
type MeshNameRequest ¶ added in v0.0.4
type MeshNameRequest struct {
// contains filtered or unexported fields
}
func (*MeshNameRequest) Descriptor
deprecated
added in
v0.0.4
func (*MeshNameRequest) Descriptor() ([]byte, []int)
Deprecated: Use MeshNameRequest.ProtoReflect.Descriptor instead.
func (*MeshNameRequest) ProtoMessage ¶ added in v0.0.4
func (*MeshNameRequest) ProtoMessage()
func (*MeshNameRequest) ProtoReflect ¶ added in v0.5.1
func (x *MeshNameRequest) ProtoReflect() protoreflect.Message
func (*MeshNameRequest) Reset ¶ added in v0.0.4
func (x *MeshNameRequest) Reset()
func (*MeshNameRequest) String ¶ added in v0.0.4
func (x *MeshNameRequest) String() string
type MeshNameResponse ¶ added in v0.0.4
type MeshNameResponse struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*MeshNameResponse) Descriptor
deprecated
added in
v0.0.4
func (*MeshNameResponse) Descriptor() ([]byte, []int)
Deprecated: Use MeshNameResponse.ProtoReflect.Descriptor instead.
func (*MeshNameResponse) GetName ¶ added in v0.0.4
func (x *MeshNameResponse) GetName() string
func (*MeshNameResponse) ProtoMessage ¶ added in v0.0.4
func (*MeshNameResponse) ProtoMessage()
func (*MeshNameResponse) ProtoReflect ¶ added in v0.5.1
func (x *MeshNameResponse) ProtoReflect() protoreflect.Message
func (*MeshNameResponse) Reset ¶ added in v0.0.4
func (x *MeshNameResponse) Reset()
func (*MeshNameResponse) String ¶ added in v0.0.4
func (x *MeshNameResponse) String() string
type MeshServiceClient ¶ added in v0.0.4
type MeshServiceClient interface { CreateMeshInstance(ctx context.Context, in *CreateMeshInstanceRequest, opts ...grpc.CallOption) (*CreateMeshInstanceResponse, error) 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 ¶ added in v0.0.4
func NewMeshServiceClient(cc grpc.ClientConnInterface) MeshServiceClient
type MeshServiceServer ¶ added in v0.0.4
type MeshServiceServer interface { CreateMeshInstance(context.Context, *CreateMeshInstanceRequest) (*CreateMeshInstanceResponse, error) 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 ¶ added in v0.0.6
type MeshService_StreamEventsClient interface { Recv() (*EventsResponse, error) grpc.ClientStream }
type MeshService_StreamEventsServer ¶ added in v0.0.6
type MeshService_StreamEventsServer interface { Send(*EventsResponse) error grpc.ServerStream }
type MeshVersionsRequest ¶ added in v0.5.2
type MeshVersionsRequest struct {
// contains filtered or unexported fields
}
func (*MeshVersionsRequest) Descriptor
deprecated
added in
v0.5.2
func (*MeshVersionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use MeshVersionsRequest.ProtoReflect.Descriptor instead.
func (*MeshVersionsRequest) ProtoMessage ¶ added in v0.5.2
func (*MeshVersionsRequest) ProtoMessage()
func (*MeshVersionsRequest) ProtoReflect ¶ added in v0.5.2
func (x *MeshVersionsRequest) ProtoReflect() protoreflect.Message
func (*MeshVersionsRequest) Reset ¶ added in v0.5.2
func (x *MeshVersionsRequest) Reset()
func (*MeshVersionsRequest) String ¶ added in v0.5.2
func (x *MeshVersionsRequest) String() string
type MeshVersionsResponse ¶ added in v0.5.2
type MeshVersionsResponse struct { Version []string `protobuf:"bytes,1,rep,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*MeshVersionsResponse) Descriptor
deprecated
added in
v0.5.2
func (*MeshVersionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use MeshVersionsResponse.ProtoReflect.Descriptor instead.
func (*MeshVersionsResponse) GetVersion ¶ added in v0.5.2
func (x *MeshVersionsResponse) GetVersion() []string
func (*MeshVersionsResponse) ProtoMessage ¶ added in v0.5.2
func (*MeshVersionsResponse) ProtoMessage()
func (*MeshVersionsResponse) ProtoReflect ¶ added in v0.5.2
func (x *MeshVersionsResponse) ProtoReflect() protoreflect.Message
func (*MeshVersionsResponse) Reset ¶ added in v0.5.2
func (x *MeshVersionsResponse) Reset()
func (*MeshVersionsResponse) String ¶ added in v0.5.2
func (x *MeshVersionsResponse) String() string
type OpCategory ¶ added in v0.0.6
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 ¶ added in v0.5.1
func (OpCategory) Descriptor() protoreflect.EnumDescriptor
func (OpCategory) Enum ¶ added in v0.5.1
func (x OpCategory) Enum() *OpCategory
func (OpCategory) EnumDescriptor
deprecated
added in
v0.0.6
func (OpCategory) EnumDescriptor() ([]byte, []int)
Deprecated: Use OpCategory.Descriptor instead.
func (OpCategory) Number ¶ added in v0.5.1
func (x OpCategory) Number() protoreflect.EnumNumber
func (OpCategory) String ¶ added in v0.0.6
func (x OpCategory) String() string
func (OpCategory) Type ¶ added in v0.5.1
func (OpCategory) Type() protoreflect.EnumType
type ProcessOAMRequest ¶ added in v0.5.1
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"` // contains filtered or unexported fields }
func (*ProcessOAMRequest) Descriptor
deprecated
added in
v0.5.1
func (*ProcessOAMRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProcessOAMRequest.ProtoReflect.Descriptor instead.
func (*ProcessOAMRequest) GetDeleteOp ¶ added in v0.5.1
func (x *ProcessOAMRequest) GetDeleteOp() bool
func (*ProcessOAMRequest) GetOamComps ¶ added in v0.5.1
func (x *ProcessOAMRequest) GetOamComps() []string
func (*ProcessOAMRequest) GetOamConfig ¶ added in v0.5.1
func (x *ProcessOAMRequest) GetOamConfig() string
func (*ProcessOAMRequest) GetUsername ¶ added in v0.5.1
func (x *ProcessOAMRequest) GetUsername() string
func (*ProcessOAMRequest) ProtoMessage ¶ added in v0.5.1
func (*ProcessOAMRequest) ProtoMessage()
func (*ProcessOAMRequest) ProtoReflect ¶ added in v0.5.1
func (x *ProcessOAMRequest) ProtoReflect() protoreflect.Message
func (*ProcessOAMRequest) Reset ¶ added in v0.5.1
func (x *ProcessOAMRequest) Reset()
func (*ProcessOAMRequest) String ¶ added in v0.5.1
func (x *ProcessOAMRequest) String() string
type ProcessOAMResponse ¶ added in v0.5.1
type ProcessOAMResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*ProcessOAMResponse) Descriptor
deprecated
added in
v0.5.1
func (*ProcessOAMResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProcessOAMResponse.ProtoReflect.Descriptor instead.
func (*ProcessOAMResponse) GetMessage ¶ added in v0.5.1
func (x *ProcessOAMResponse) GetMessage() string
func (*ProcessOAMResponse) ProtoMessage ¶ added in v0.5.1
func (*ProcessOAMResponse) ProtoMessage()
func (*ProcessOAMResponse) ProtoReflect ¶ added in v0.5.1
func (x *ProcessOAMResponse) ProtoReflect() protoreflect.Message
func (*ProcessOAMResponse) Reset ¶ added in v0.5.1
func (x *ProcessOAMResponse) Reset()
func (*ProcessOAMResponse) String ¶ added in v0.5.1
func (x *ProcessOAMResponse) String() string
type SupportedOperation ¶ added in v0.0.4
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
added in
v0.0.4
func (*SupportedOperation) Descriptor() ([]byte, []int)
Deprecated: Use SupportedOperation.ProtoReflect.Descriptor instead.
func (*SupportedOperation) GetCategory ¶ added in v0.0.6
func (x *SupportedOperation) GetCategory() OpCategory
func (*SupportedOperation) GetKey ¶ added in v0.0.4
func (x *SupportedOperation) GetKey() string
func (*SupportedOperation) GetValue ¶ added in v0.0.4
func (x *SupportedOperation) GetValue() string
func (*SupportedOperation) ProtoMessage ¶ added in v0.0.4
func (*SupportedOperation) ProtoMessage()
func (*SupportedOperation) ProtoReflect ¶ added in v0.5.1
func (x *SupportedOperation) ProtoReflect() protoreflect.Message
func (*SupportedOperation) Reset ¶ added in v0.0.4
func (x *SupportedOperation) Reset()
func (*SupportedOperation) String ¶ added in v0.0.4
func (x *SupportedOperation) String() string
type SupportedOperationsRequest ¶ added in v0.0.4
type SupportedOperationsRequest struct {
// contains filtered or unexported fields
}
func (*SupportedOperationsRequest) Descriptor
deprecated
added in
v0.0.4
func (*SupportedOperationsRequest) Descriptor() ([]byte, []int)
Deprecated: Use SupportedOperationsRequest.ProtoReflect.Descriptor instead.
func (*SupportedOperationsRequest) ProtoMessage ¶ added in v0.0.4
func (*SupportedOperationsRequest) ProtoMessage()
func (*SupportedOperationsRequest) ProtoReflect ¶ added in v0.5.1
func (x *SupportedOperationsRequest) ProtoReflect() protoreflect.Message
func (*SupportedOperationsRequest) Reset ¶ added in v0.0.4
func (x *SupportedOperationsRequest) Reset()
func (*SupportedOperationsRequest) String ¶ added in v0.0.4
func (x *SupportedOperationsRequest) String() string
type SupportedOperationsResponse ¶ added in v0.0.4
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
added in
v0.0.4
func (*SupportedOperationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use SupportedOperationsResponse.ProtoReflect.Descriptor instead.
func (*SupportedOperationsResponse) GetError ¶ added in v0.0.4
func (x *SupportedOperationsResponse) GetError() string
func (*SupportedOperationsResponse) GetOps ¶ added in v0.0.4
func (x *SupportedOperationsResponse) GetOps() []*SupportedOperation
func (*SupportedOperationsResponse) ProtoMessage ¶ added in v0.0.4
func (*SupportedOperationsResponse) ProtoMessage()
func (*SupportedOperationsResponse) ProtoReflect ¶ added in v0.5.1
func (x *SupportedOperationsResponse) ProtoReflect() protoreflect.Message
func (*SupportedOperationsResponse) Reset ¶ added in v0.0.4
func (x *SupportedOperationsResponse) Reset()
func (*SupportedOperationsResponse) String ¶ added in v0.0.4
func (x *SupportedOperationsResponse) String() string
type UnimplementedMeshServiceServer ¶ added in v0.5.1
type UnimplementedMeshServiceServer struct { }
UnimplementedMeshServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedMeshServiceServer) ApplyOperation ¶ added in v0.5.1
func (UnimplementedMeshServiceServer) ApplyOperation(context.Context, *ApplyRuleRequest) (*ApplyRuleResponse, error)
func (UnimplementedMeshServiceServer) ComponentInfo ¶ added in v0.5.2
func (UnimplementedMeshServiceServer) ComponentInfo(context.Context, *ComponentInfoRequest) (*ComponentInfoResponse, error)
func (UnimplementedMeshServiceServer) CreateMeshInstance ¶ added in v0.5.1
func (UnimplementedMeshServiceServer) CreateMeshInstance(context.Context, *CreateMeshInstanceRequest) (*CreateMeshInstanceResponse, error)
func (UnimplementedMeshServiceServer) MeshName ¶ added in v0.5.1
func (UnimplementedMeshServiceServer) MeshName(context.Context, *MeshNameRequest) (*MeshNameResponse, error)
func (UnimplementedMeshServiceServer) MeshVersions ¶ added in v0.5.2
func (UnimplementedMeshServiceServer) MeshVersions(context.Context, *MeshVersionsRequest) (*MeshVersionsResponse, error)
func (UnimplementedMeshServiceServer) ProcessOAM ¶ added in v0.5.1
func (UnimplementedMeshServiceServer) ProcessOAM(context.Context, *ProcessOAMRequest) (*ProcessOAMResponse, error)
func (UnimplementedMeshServiceServer) StreamEvents ¶ added in v0.5.1
func (UnimplementedMeshServiceServer) StreamEvents(*EventsRequest, MeshService_StreamEventsServer) error
func (UnimplementedMeshServiceServer) SupportedOperations ¶ added in v0.5.1
func (UnimplementedMeshServiceServer) SupportedOperations(context.Context, *SupportedOperationsRequest) (*SupportedOperationsResponse, error)
type UnsafeMeshServiceServer ¶ added in v0.5.1
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.