meshes

package
v0.4.4 Latest Latest
Warning

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

 Go to latest Published: Jul 23, 2023 License: MIT Imports: 8 Imported by: 4

Documentation

Index

Constants

View Source 
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_CloudStreamEvents_FullMethodName   = "/meshes.MeshService/CloudStreamEvents"
	MeshService_ProcessOAM_FullMethodName          = "/meshes.MeshService/ProcessOAM"
	MeshService_ComponentInfo_FullMethodName       = "/meshes.MeshService/ComponentInfo"
	MeshService_Ping_FullMethodName                = "/meshes.MeshService/Ping"
)

Variables

View Source 
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.

View Source 
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.

View Source 
var File_meshops_proto protoreflect.FileDescriptor
View Source 
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:    "CloudStreamEvents",
			Handler:       _MeshService_CloudStreamEvents_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) Descriptor deprecated 

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

Deprecated: Use Adapter.ProtoReflect.Descriptor instead.

func (*Adapter) GetHost 

func (x *Adapter) GetHost() string

func (*Adapter) GetName 

func (x *Adapter) GetName() string

func (*Adapter) GetPort 

func (x *Adapter) GetPort() string

func (*Adapter) ProtoMessage 

func (*Adapter) ProtoMessage()

func (*Adapter) ProtoReflect 

func (x *Adapter) ProtoReflect() protoreflect.Message

func (*Adapter) Reset 

func (x *Adapter) Reset()

func (*Adapter) String 

func (x *Adapter) String() string

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 CloudEventsRequest added in v0.4.3 

type CloudEventsRequest struct {
	// contains filtered or unexported fields
}

func (*CloudEventsRequest) Descriptor deprecated added in v0.4.3 

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

Deprecated: Use CloudEventsRequest.ProtoReflect.Descriptor instead.

func (*CloudEventsRequest) ProtoMessage added in v0.4.3 

func (*CloudEventsRequest) ProtoMessage()

func (*CloudEventsRequest) ProtoReflect added in v0.4.3 

func (x *CloudEventsRequest) ProtoReflect() protoreflect.Message

func (*CloudEventsRequest) Reset added in v0.4.3 

func (x *CloudEventsRequest) Reset()

func (*CloudEventsRequest) String added in v0.4.3 

func (x *CloudEventsRequest) String() string

type CloudEventsResponse added in v0.4.3 

type CloudEventsResponse 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 (*CloudEventsResponse) Descriptor deprecated added in v0.4.3 

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

Deprecated: Use CloudEventsResponse.ProtoReflect.Descriptor instead.

func (*CloudEventsResponse) GetComponent added in v0.4.3 

func (x *CloudEventsResponse) GetComponent() string

func (*CloudEventsResponse) GetComponentName added in v0.4.3 

func (x *CloudEventsResponse) GetComponentName() string

func (*CloudEventsResponse) GetDetails added in v0.4.3 

func (x *CloudEventsResponse) GetDetails() string

func (*CloudEventsResponse) GetErrorCode added in v0.4.3 

func (x *CloudEventsResponse) GetErrorCode() string

func (*CloudEventsResponse) GetEventType added in v0.4.4 

func (x *CloudEventsResponse) GetEventType() EventType

func (*CloudEventsResponse) GetOperationId added in v0.4.3 

func (x *CloudEventsResponse) GetOperationId() string

func (*CloudEventsResponse) GetProbableCause added in v0.4.3 

func (x *CloudEventsResponse) GetProbableCause() string

func (*CloudEventsResponse) GetSuggestedRemediation added in v0.4.3 

func (x *CloudEventsResponse) GetSuggestedRemediation() string

func (*CloudEventsResponse) GetSummary added in v0.4.3 

func (x *CloudEventsResponse) GetSummary() string

func (*CloudEventsResponse) ProtoMessage added in v0.4.3 

func (*CloudEventsResponse) ProtoMessage()

func (*CloudEventsResponse) ProtoReflect added in v0.4.3 

func (x *CloudEventsResponse) ProtoReflect() protoreflect.Message

func (*CloudEventsResponse) Reset added in v0.4.3 

func (x *CloudEventsResponse) Reset()

func (*CloudEventsResponse) String added in v0.4.3 

func (x *CloudEventsResponse) 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 EventType added in v0.4.4 

type EventType int32
const (
	EventType_INFO  EventType = 0
	EventType_WARN  EventType = 1
	EventType_ERROR EventType = 2
)

func (EventType) Descriptor added in v0.4.4 

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum added in v0.4.4 

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated added in v0.4.4 

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

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number added in v0.4.4 

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String added in v0.4.4 

func (x EventType) String() string

func (EventType) Type added in v0.4.4 

func (EventType) Type() protoreflect.EnumType

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)
	CloudStreamEvents(ctx context.Context, in *CloudEventsRequest, opts ...grpc.CallOption) (MeshService_CloudStreamEventsClient, 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)
	CloudStreamEvents(*CloudEventsRequest, MeshService_CloudStreamEventsServer) 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_CloudStreamEventsClient added in v0.4.3 

type MeshService_CloudStreamEventsClient interface {
	Recv() (*CloudEventsResponse, error)
	grpc.ClientStream
}

type MeshService_CloudStreamEventsServer added in v0.4.3 

type MeshService_CloudStreamEventsServer interface {
	Send(*CloudEventsResponse) 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) CloudStreamEvents added in v0.4.3 

func (UnimplementedMeshServiceServer) CloudStreamEvents(*CloudEventsRequest, MeshService_CloudStreamEventsServer) 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) 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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.