meshes

package
v0.3.19 Latest Latest
Warning

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

 Go to latest Published: Nov 5, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EventType_name = map[int32]string{
	0: "INFO",
	1: "WARN",
	2: "ERROR",
}
View Source 
var EventType_value = map[string]int32{
	"INFO":  0,
	"WARN":  1,
	"ERROR": 2,
}
View Source 
var OpCategory_name = map[int32]string{
	0: "INSTALL",
	1: "SAMPLE_APPLICATION",
	2: "CONFIGURE",
	3: "VALIDATE",
	4: "CUSTOM",
}
View Source 
var OpCategory_value = map[string]int32{
	"INSTALL":            0,
	"SAMPLE_APPLICATION": 1,
	"CONFIGURE":          2,
	"VALIDATE":           3,
	"CUSTOM":             4,
}

Functions

func RegisterMeshServiceServer 

func RegisterMeshServiceServer(s *grpc.Server, 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ApplyRuleRequest) Descriptor 

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

func (*ApplyRuleRequest) GetCustomBody 

func (m *ApplyRuleRequest) GetCustomBody() string

func (*ApplyRuleRequest) GetDeleteOp 

func (m *ApplyRuleRequest) GetDeleteOp() bool

func (*ApplyRuleRequest) GetNamespace 

func (m *ApplyRuleRequest) GetNamespace() string

func (*ApplyRuleRequest) GetOpName 

func (m *ApplyRuleRequest) GetOpName() string

func (*ApplyRuleRequest) GetOperationId 

func (m *ApplyRuleRequest) GetOperationId() string

func (*ApplyRuleRequest) GetUsername 

func (m *ApplyRuleRequest) GetUsername() string

func (*ApplyRuleRequest) ProtoMessage 

func (*ApplyRuleRequest) ProtoMessage()

func (*ApplyRuleRequest) Reset 

func (m *ApplyRuleRequest) Reset()

func (*ApplyRuleRequest) String 

func (m *ApplyRuleRequest) String() string

func (*ApplyRuleRequest) XXX_DiscardUnknown 

func (m *ApplyRuleRequest) XXX_DiscardUnknown()

func (*ApplyRuleRequest) XXX_Marshal 

func (m *ApplyRuleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplyRuleRequest) XXX_Merge 

func (dst *ApplyRuleRequest) XXX_Merge(src proto.Message)

func (*ApplyRuleRequest) XXX_Size 

func (m *ApplyRuleRequest) XXX_Size() int

func (*ApplyRuleRequest) XXX_Unmarshal 

func (m *ApplyRuleRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ApplyRuleResponse) Descriptor 

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

func (*ApplyRuleResponse) GetError 

func (m *ApplyRuleResponse) GetError() string

func (*ApplyRuleResponse) GetOperationId 

func (m *ApplyRuleResponse) GetOperationId() string

func (*ApplyRuleResponse) ProtoMessage 

func (*ApplyRuleResponse) ProtoMessage()

func (*ApplyRuleResponse) Reset 

func (m *ApplyRuleResponse) Reset()

func (*ApplyRuleResponse) String 

func (m *ApplyRuleResponse) String() string

func (*ApplyRuleResponse) XXX_DiscardUnknown 

func (m *ApplyRuleResponse) XXX_DiscardUnknown()

func (*ApplyRuleResponse) XXX_Marshal 

func (m *ApplyRuleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplyRuleResponse) XXX_Merge 

func (dst *ApplyRuleResponse) XXX_Merge(src proto.Message)

func (*ApplyRuleResponse) XXX_Size 

func (m *ApplyRuleResponse) XXX_Size() int

func (*ApplyRuleResponse) XXX_Unmarshal 

func (m *ApplyRuleResponse) XXX_Unmarshal(b []byte) error

type CreateMeshInstanceRequest 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateMeshInstanceRequest) Descriptor 

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

func (*CreateMeshInstanceRequest) GetContextName 

func (m *CreateMeshInstanceRequest) GetContextName() string

func (*CreateMeshInstanceRequest) GetK8SConfig 

func (m *CreateMeshInstanceRequest) GetK8SConfig() []byte

func (*CreateMeshInstanceRequest) ProtoMessage 

func (*CreateMeshInstanceRequest) ProtoMessage()

func (*CreateMeshInstanceRequest) Reset 

func (m *CreateMeshInstanceRequest) Reset()

func (*CreateMeshInstanceRequest) String 

func (m *CreateMeshInstanceRequest) String() string

func (*CreateMeshInstanceRequest) XXX_DiscardUnknown 

func (m *CreateMeshInstanceRequest) XXX_DiscardUnknown()

func (*CreateMeshInstanceRequest) XXX_Marshal 

func (m *CreateMeshInstanceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateMeshInstanceRequest) XXX_Merge 

func (dst *CreateMeshInstanceRequest) XXX_Merge(src proto.Message)

func (*CreateMeshInstanceRequest) XXX_Size 

func (m *CreateMeshInstanceRequest) XXX_Size() int

func (*CreateMeshInstanceRequest) XXX_Unmarshal 

func (m *CreateMeshInstanceRequest) XXX_Unmarshal(b []byte) error

type CreateMeshInstanceResponse 

type CreateMeshInstanceResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateMeshInstanceResponse) Descriptor 

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

func (*CreateMeshInstanceResponse) ProtoMessage 

func (*CreateMeshInstanceResponse) ProtoMessage()

func (*CreateMeshInstanceResponse) Reset 

func (m *CreateMeshInstanceResponse) Reset()

func (*CreateMeshInstanceResponse) String 

func (m *CreateMeshInstanceResponse) String() string

func (*CreateMeshInstanceResponse) XXX_DiscardUnknown 

func (m *CreateMeshInstanceResponse) XXX_DiscardUnknown()

func (*CreateMeshInstanceResponse) XXX_Marshal 

func (m *CreateMeshInstanceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateMeshInstanceResponse) XXX_Merge 

func (dst *CreateMeshInstanceResponse) XXX_Merge(src proto.Message)

func (*CreateMeshInstanceResponse) XXX_Size 

func (m *CreateMeshInstanceResponse) XXX_Size() int

func (*CreateMeshInstanceResponse) XXX_Unmarshal 

func (m *CreateMeshInstanceResponse) XXX_Unmarshal(b []byte) error

type EventType 

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

func (EventType) EnumDescriptor 

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

func (EventType) String 

func (x EventType) String() string

type EventsRequest 

type EventsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventsRequest) Descriptor 

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

func (*EventsRequest) ProtoMessage 

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) Reset 

func (m *EventsRequest) Reset()

func (*EventsRequest) String 

func (m *EventsRequest) String() string

func (*EventsRequest) XXX_DiscardUnknown 

func (m *EventsRequest) XXX_DiscardUnknown()

func (*EventsRequest) XXX_Marshal 

func (m *EventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventsRequest) XXX_Merge 

func (dst *EventsRequest) XXX_Merge(src proto.Message)

func (*EventsRequest) XXX_Size 

func (m *EventsRequest) XXX_Size() int

func (*EventsRequest) XXX_Unmarshal 

func (m *EventsRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*EventsResponse) Descriptor 

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

func (*EventsResponse) GetDetails 

func (m *EventsResponse) GetDetails() string

func (*EventsResponse) GetEventType 

func (m *EventsResponse) GetEventType() EventType

func (*EventsResponse) GetOperationId 

func (m *EventsResponse) GetOperationId() string

func (*EventsResponse) GetSummary 

func (m *EventsResponse) GetSummary() string

func (*EventsResponse) ProtoMessage 

func (*EventsResponse) ProtoMessage()

func (*EventsResponse) Reset 

func (m *EventsResponse) Reset()

func (*EventsResponse) String 

func (m *EventsResponse) String() string

func (*EventsResponse) XXX_DiscardUnknown 

func (m *EventsResponse) XXX_DiscardUnknown()

func (*EventsResponse) XXX_Marshal 

func (m *EventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventsResponse) XXX_Merge 

func (dst *EventsResponse) XXX_Merge(src proto.Message)

func (*EventsResponse) XXX_Size 

func (m *EventsResponse) XXX_Size() int

func (*EventsResponse) XXX_Unmarshal 

func (m *EventsResponse) XXX_Unmarshal(b []byte) error

type MeshNameRequest 

type MeshNameRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MeshNameRequest) Descriptor 

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

func (*MeshNameRequest) ProtoMessage 

func (*MeshNameRequest) ProtoMessage()

func (*MeshNameRequest) Reset 

func (m *MeshNameRequest) Reset()

func (*MeshNameRequest) String 

func (m *MeshNameRequest) String() string

func (*MeshNameRequest) XXX_DiscardUnknown 

func (m *MeshNameRequest) XXX_DiscardUnknown()

func (*MeshNameRequest) XXX_Marshal 

func (m *MeshNameRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshNameRequest) XXX_Merge 

func (dst *MeshNameRequest) XXX_Merge(src proto.Message)

func (*MeshNameRequest) XXX_Size 

func (m *MeshNameRequest) XXX_Size() int

func (*MeshNameRequest) XXX_Unmarshal 

func (m *MeshNameRequest) XXX_Unmarshal(b []byte) error

type MeshNameResponse 

type MeshNameResponse struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MeshNameResponse) Descriptor 

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

func (*MeshNameResponse) GetName 

func (m *MeshNameResponse) GetName() string

func (*MeshNameResponse) ProtoMessage 

func (*MeshNameResponse) ProtoMessage()

func (*MeshNameResponse) Reset 

func (m *MeshNameResponse) Reset()

func (*MeshNameResponse) String 

func (m *MeshNameResponse) String() string

func (*MeshNameResponse) XXX_DiscardUnknown 

func (m *MeshNameResponse) XXX_DiscardUnknown()

func (*MeshNameResponse) XXX_Marshal 

func (m *MeshNameResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeshNameResponse) XXX_Merge 

func (dst *MeshNameResponse) XXX_Merge(src proto.Message)

func (*MeshNameResponse) XXX_Size 

func (m *MeshNameResponse) XXX_Size() int

func (*MeshNameResponse) XXX_Unmarshal 

func (m *MeshNameResponse) XXX_Unmarshal(b []byte) error

type MeshServiceClient 

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

MeshServiceClient is the client API for MeshService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMeshServiceClient 

func NewMeshServiceClient(cc *grpc.ClientConn) MeshServiceClient

type MeshServiceServer 

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
}

MeshServiceServer is the server API for MeshService service.

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

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

func (OpCategory) String 

func (x OpCategory) 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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*SupportedOperation) Descriptor 

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

func (*SupportedOperation) GetCategory 

func (m *SupportedOperation) GetCategory() OpCategory

func (*SupportedOperation) GetKey 

func (m *SupportedOperation) GetKey() string

func (*SupportedOperation) GetValue 

func (m *SupportedOperation) GetValue() string

func (*SupportedOperation) ProtoMessage 

func (*SupportedOperation) ProtoMessage()

func (*SupportedOperation) Reset 

func (m *SupportedOperation) Reset()

func (*SupportedOperation) String 

func (m *SupportedOperation) String() string

func (*SupportedOperation) XXX_DiscardUnknown 

func (m *SupportedOperation) XXX_DiscardUnknown()

func (*SupportedOperation) XXX_Marshal 

func (m *SupportedOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SupportedOperation) XXX_Merge 

func (dst *SupportedOperation) XXX_Merge(src proto.Message)

func (*SupportedOperation) XXX_Size 

func (m *SupportedOperation) XXX_Size() int

func (*SupportedOperation) XXX_Unmarshal 

func (m *SupportedOperation) XXX_Unmarshal(b []byte) error

type SupportedOperationsRequest 

type SupportedOperationsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SupportedOperationsRequest) Descriptor 

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

func (*SupportedOperationsRequest) ProtoMessage 

func (*SupportedOperationsRequest) ProtoMessage()

func (*SupportedOperationsRequest) Reset 

func (m *SupportedOperationsRequest) Reset()

func (*SupportedOperationsRequest) String 

func (m *SupportedOperationsRequest) String() string

func (*SupportedOperationsRequest) XXX_DiscardUnknown 

func (m *SupportedOperationsRequest) XXX_DiscardUnknown()

func (*SupportedOperationsRequest) XXX_Marshal 

func (m *SupportedOperationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SupportedOperationsRequest) XXX_Merge 

func (dst *SupportedOperationsRequest) XXX_Merge(src proto.Message)

func (*SupportedOperationsRequest) XXX_Size 

func (m *SupportedOperationsRequest) XXX_Size() int

func (*SupportedOperationsRequest) XXX_Unmarshal 

func (m *SupportedOperationsRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*SupportedOperationsResponse) Descriptor 

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

func (*SupportedOperationsResponse) GetError 

func (m *SupportedOperationsResponse) GetError() string

func (*SupportedOperationsResponse) GetOps 

func (m *SupportedOperationsResponse) GetOps() []*SupportedOperation

func (*SupportedOperationsResponse) ProtoMessage 

func (*SupportedOperationsResponse) ProtoMessage()

func (*SupportedOperationsResponse) Reset 

func (m *SupportedOperationsResponse) Reset()

func (*SupportedOperationsResponse) String 

func (m *SupportedOperationsResponse) String() string

func (*SupportedOperationsResponse) XXX_DiscardUnknown 

func (m *SupportedOperationsResponse) XXX_DiscardUnknown()

func (*SupportedOperationsResponse) XXX_Marshal 

func (m *SupportedOperationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SupportedOperationsResponse) XXX_Merge 

func (dst *SupportedOperationsResponse) XXX_Merge(src proto.Message)

func (*SupportedOperationsResponse) XXX_Size 

func (m *SupportedOperationsResponse) XXX_Size() int

func (*SupportedOperationsResponse) XXX_Unmarshal 

func (m *SupportedOperationsResponse) XXX_Unmarshal(b []byte) error

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.