meshes

package
v0.5.0-rc-4 Latest Latest
Warning

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

Go to latest
Published: Mar 3, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

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

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 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 (*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 (*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
const (
	EventType_INFO  EventType = 0
	EventType_WARN  EventType = 1
	EventType_ERROR EventType = 2
)

func (EventType) Descriptor added in v0.5.1

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum added in v0.5.1

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated added in v0.0.6

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

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number added in v0.5.1

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String added in v0.0.6

func (x EventType) String() string

func (EventType) Type added in v0.5.1

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)
	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)
}

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)
	ApplyOperation(context.Context, *ApplyRuleRequest) (*ApplyRuleResponse, error)
	SupportedOperations(context.Context, *SupportedOperationsRequest) (*SupportedOperationsResponse, error)
	StreamEvents(*EventsRequest, MeshService_StreamEventsServer) error
	ProcessOAM(context.Context, *ProcessOAMRequest) (*ProcessOAMResponse, 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 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

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 (*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 (*SupportedOperationsResponse) ProtoMessage added in v0.0.4

func (*SupportedOperationsResponse) ProtoMessage()

func (*SupportedOperationsResponse) ProtoReflect added in v0.5.1

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) CreateMeshInstance added in v0.5.1

func (UnimplementedMeshServiceServer) MeshName added in v0.5.1

func (UnimplementedMeshServiceServer) ProcessOAM added in v0.5.1

func (UnimplementedMeshServiceServer) StreamEvents added in v0.5.1

func (UnimplementedMeshServiceServer) SupportedOperations added in v0.5.1

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL