vzconnpb

package
v0.0.0-...-8540621 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterVZConnServiceServer 

func RegisterVZConnServiceServer(s *grpc.Server, srv VZConnServiceServer)

Types

type C2VBridgeMessage 

type C2VBridgeMessage struct {
	Topic string     `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Msg   *types.Any `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*C2VBridgeMessage) Descriptor 

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

func (*C2VBridgeMessage) Equal 

func (this *C2VBridgeMessage) Equal(that interface{}) bool

func (*C2VBridgeMessage) GetMsg 

func (m *C2VBridgeMessage) GetMsg() *types.Any

func (*C2VBridgeMessage) GetTopic 

func (m *C2VBridgeMessage) GetTopic() string

func (*C2VBridgeMessage) GoString 

func (this *C2VBridgeMessage) GoString() string

func (*C2VBridgeMessage) Marshal 

func (m *C2VBridgeMessage) Marshal() (dAtA []byte, err error)

func (*C2VBridgeMessage) MarshalTo 

func (m *C2VBridgeMessage) MarshalTo(dAtA []byte) (int, error)

func (*C2VBridgeMessage) MarshalToSizedBuffer 

func (m *C2VBridgeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*C2VBridgeMessage) ProtoMessage 

func (*C2VBridgeMessage) ProtoMessage()

func (*C2VBridgeMessage) Reset 

func (m *C2VBridgeMessage) Reset()

func (*C2VBridgeMessage) Size 

func (m *C2VBridgeMessage) Size() (n int)

func (*C2VBridgeMessage) String 

func (this *C2VBridgeMessage) String() string

func (*C2VBridgeMessage) Unmarshal 

func (m *C2VBridgeMessage) Unmarshal(dAtA []byte) error

func (*C2VBridgeMessage) XXX_DiscardUnknown 

func (m *C2VBridgeMessage) XXX_DiscardUnknown()

func (*C2VBridgeMessage) XXX_Marshal 

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

func (*C2VBridgeMessage) XXX_Merge 

func (m *C2VBridgeMessage) XXX_Merge(src proto.Message)

func (*C2VBridgeMessage) XXX_Size 

func (m *C2VBridgeMessage) XXX_Size() int

func (*C2VBridgeMessage) XXX_Unmarshal 

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

type RegisterVizierDeploymentRequest 

type RegisterVizierDeploymentRequest struct {
	K8sClusterUID  string `protobuf:"bytes,1,opt,name=k8s_cluster_uid,json=k8sClusterUid,proto3" json:"k8s_cluster_uid,omitempty"`
	K8sClusterName string `protobuf:"bytes,2,opt,name=k8s_cluster_name,json=k8sClusterName,proto3" json:"k8s_cluster_name,omitempty"`
}

func (*RegisterVizierDeploymentRequest) Descriptor 

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

func (*RegisterVizierDeploymentRequest) Equal 

func (this *RegisterVizierDeploymentRequest) Equal(that interface{}) bool

func (*RegisterVizierDeploymentRequest) GetK8sClusterName 

func (m *RegisterVizierDeploymentRequest) GetK8sClusterName() string

func (*RegisterVizierDeploymentRequest) GetK8sClusterUID 

func (m *RegisterVizierDeploymentRequest) GetK8sClusterUID() string

func (*RegisterVizierDeploymentRequest) GoString 

func (this *RegisterVizierDeploymentRequest) GoString() string

func (*RegisterVizierDeploymentRequest) Marshal 

func (m *RegisterVizierDeploymentRequest) Marshal() (dAtA []byte, err error)

func (*RegisterVizierDeploymentRequest) MarshalTo 

func (m *RegisterVizierDeploymentRequest) MarshalTo(dAtA []byte) (int, error)

func (*RegisterVizierDeploymentRequest) MarshalToSizedBuffer 

func (m *RegisterVizierDeploymentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterVizierDeploymentRequest) ProtoMessage 

func (*RegisterVizierDeploymentRequest) ProtoMessage()

func (*RegisterVizierDeploymentRequest) Reset 

func (m *RegisterVizierDeploymentRequest) Reset()

func (*RegisterVizierDeploymentRequest) Size 

func (m *RegisterVizierDeploymentRequest) Size() (n int)

func (*RegisterVizierDeploymentRequest) String 

func (this *RegisterVizierDeploymentRequest) String() string

func (*RegisterVizierDeploymentRequest) Unmarshal 

func (m *RegisterVizierDeploymentRequest) Unmarshal(dAtA []byte) error

func (*RegisterVizierDeploymentRequest) XXX_DiscardUnknown 

func (m *RegisterVizierDeploymentRequest) XXX_DiscardUnknown()

func (*RegisterVizierDeploymentRequest) XXX_Marshal 

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

func (*RegisterVizierDeploymentRequest) XXX_Merge 

func (m *RegisterVizierDeploymentRequest) XXX_Merge(src proto.Message)

func (*RegisterVizierDeploymentRequest) XXX_Size 

func (m *RegisterVizierDeploymentRequest) XXX_Size() int

func (*RegisterVizierDeploymentRequest) XXX_Unmarshal 

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

type RegisterVizierDeploymentResponse 

type RegisterVizierDeploymentResponse struct {
	VizierID   *uuidpb.UUID `protobuf:"bytes,1,opt,name=vizier_id,json=vizierId,proto3" json:"vizier_id,omitempty"`
	VizierName string       `protobuf:"bytes,2,opt,name=vizier_name,json=vizierName,proto3" json:"vizier_name,omitempty"`
}

func (*RegisterVizierDeploymentResponse) Descriptor 

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

func (*RegisterVizierDeploymentResponse) Equal 

func (this *RegisterVizierDeploymentResponse) Equal(that interface{}) bool

func (*RegisterVizierDeploymentResponse) GetVizierID 

func (m *RegisterVizierDeploymentResponse) GetVizierID() *uuidpb.UUID

func (*RegisterVizierDeploymentResponse) GetVizierName 

func (m *RegisterVizierDeploymentResponse) GetVizierName() string

func (*RegisterVizierDeploymentResponse) GoString 

func (this *RegisterVizierDeploymentResponse) GoString() string

func (*RegisterVizierDeploymentResponse) Marshal 

func (m *RegisterVizierDeploymentResponse) Marshal() (dAtA []byte, err error)

func (*RegisterVizierDeploymentResponse) MarshalTo 

func (m *RegisterVizierDeploymentResponse) MarshalTo(dAtA []byte) (int, error)

func (*RegisterVizierDeploymentResponse) MarshalToSizedBuffer 

func (m *RegisterVizierDeploymentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterVizierDeploymentResponse) ProtoMessage 

func (*RegisterVizierDeploymentResponse) ProtoMessage()

func (*RegisterVizierDeploymentResponse) Reset 

func (m *RegisterVizierDeploymentResponse) Reset()

func (*RegisterVizierDeploymentResponse) Size 

func (m *RegisterVizierDeploymentResponse) Size() (n int)

func (*RegisterVizierDeploymentResponse) String 

func (this *RegisterVizierDeploymentResponse) String() string

func (*RegisterVizierDeploymentResponse) Unmarshal 

func (m *RegisterVizierDeploymentResponse) Unmarshal(dAtA []byte) error

func (*RegisterVizierDeploymentResponse) XXX_DiscardUnknown 

func (m *RegisterVizierDeploymentResponse) XXX_DiscardUnknown()

func (*RegisterVizierDeploymentResponse) XXX_Marshal 

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

func (*RegisterVizierDeploymentResponse) XXX_Merge 

func (m *RegisterVizierDeploymentResponse) XXX_Merge(src proto.Message)

func (*RegisterVizierDeploymentResponse) XXX_Size 

func (m *RegisterVizierDeploymentResponse) XXX_Size() int

func (*RegisterVizierDeploymentResponse) XXX_Unmarshal 

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

type UnimplementedVZConnServiceServer 

type UnimplementedVZConnServiceServer struct {
}

UnimplementedVZConnServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedVZConnServiceServer) NATSBridge 

func (*UnimplementedVZConnServiceServer) NATSBridge(srv VZConnService_NATSBridgeServer) error

func (*UnimplementedVZConnServiceServer) RegisterVizierDeployment 

func (*UnimplementedVZConnServiceServer) RegisterVizierDeployment(ctx context.Context, req *RegisterVizierDeploymentRequest) (*RegisterVizierDeploymentResponse, error)

type V2CBridgeMessage 

type V2CBridgeMessage struct {
	Topic     string     `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	SessionId int64      `protobuf:"varint,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Msg       *types.Any `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*V2CBridgeMessage) Descriptor 

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

func (*V2CBridgeMessage) Equal 

func (this *V2CBridgeMessage) Equal(that interface{}) bool

func (*V2CBridgeMessage) GetMsg 

func (m *V2CBridgeMessage) GetMsg() *types.Any

func (*V2CBridgeMessage) GetSessionId 

func (m *V2CBridgeMessage) GetSessionId() int64

func (*V2CBridgeMessage) GetTopic 

func (m *V2CBridgeMessage) GetTopic() string

func (*V2CBridgeMessage) GoString 

func (this *V2CBridgeMessage) GoString() string

func (*V2CBridgeMessage) Marshal 

func (m *V2CBridgeMessage) Marshal() (dAtA []byte, err error)

func (*V2CBridgeMessage) MarshalTo 

func (m *V2CBridgeMessage) MarshalTo(dAtA []byte) (int, error)

func (*V2CBridgeMessage) MarshalToSizedBuffer 

func (m *V2CBridgeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*V2CBridgeMessage) ProtoMessage 

func (*V2CBridgeMessage) ProtoMessage()

func (*V2CBridgeMessage) Reset 

func (m *V2CBridgeMessage) Reset()

func (*V2CBridgeMessage) Size 

func (m *V2CBridgeMessage) Size() (n int)

func (*V2CBridgeMessage) String 

func (this *V2CBridgeMessage) String() string

func (*V2CBridgeMessage) Unmarshal 

func (m *V2CBridgeMessage) Unmarshal(dAtA []byte) error

func (*V2CBridgeMessage) XXX_DiscardUnknown 

func (m *V2CBridgeMessage) XXX_DiscardUnknown()

func (*V2CBridgeMessage) XXX_Marshal 

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

func (*V2CBridgeMessage) XXX_Merge 

func (m *V2CBridgeMessage) XXX_Merge(src proto.Message)

func (*V2CBridgeMessage) XXX_Size 

func (m *V2CBridgeMessage) XXX_Size() int

func (*V2CBridgeMessage) XXX_Unmarshal 

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

type VZConnServiceClient 

type VZConnServiceClient interface {
	RegisterVizierDeployment(ctx context.Context, in *RegisterVizierDeploymentRequest, opts ...grpc.CallOption) (*RegisterVizierDeploymentResponse, error)
	NATSBridge(ctx context.Context, opts ...grpc.CallOption) (VZConnService_NATSBridgeClient, error)
}

VZConnServiceClient is the client API for VZConnService service.

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

func NewVZConnServiceClient 

func NewVZConnServiceClient(cc *grpc.ClientConn) VZConnServiceClient

type VZConnServiceServer 

type VZConnServiceServer interface {
	RegisterVizierDeployment(context.Context, *RegisterVizierDeploymentRequest) (*RegisterVizierDeploymentResponse, error)
	NATSBridge(VZConnService_NATSBridgeServer) error
}

VZConnServiceServer is the server API for VZConnService service.

type VZConnService_NATSBridgeClient 

type VZConnService_NATSBridgeClient interface {
	Send(*V2CBridgeMessage) error
	Recv() (*C2VBridgeMessage, error)
	grpc.ClientStream
}

type VZConnService_NATSBridgeServer 

type VZConnService_NATSBridgeServer interface {
	Send(*C2VBridgeMessage) error
	Recv() (*V2CBridgeMessage, error)
	grpc.ServerStream
}

Source Files

View all Source files

Directories

Path Synopsis
Package mock_vzconnpb is a generated GoMock package.
 Package mock_vzconnpb is a generated GoMock package.

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.