rpc

Documentation

Index

• Variables
• func RegisterMarbleServer(s grpc.ServiceRegistrar, srv MarbleServer)
• type ActivationReq
  • func (*ActivationReq) Descriptor() ([]byte, []int)
  • func (x *ActivationReq) GetCSR() []byte
  • func (x *ActivationReq) GetMarbleType() string
  • func (x *ActivationReq) GetQuote() []byte
  • func (x *ActivationReq) GetUUID() string
  • func (*ActivationReq) ProtoMessage()
  • func (x *ActivationReq) ProtoReflect() protoreflect.Message
  • func (x *ActivationReq) Reset()
  • func (x *ActivationReq) String() string
• type ActivationResp
  • func (*ActivationResp) Descriptor() ([]byte, []int)
  • func (x *ActivationResp) GetParameters() *Parameters
  • func (*ActivationResp) ProtoMessage()
  • func (x *ActivationResp) ProtoReflect() protoreflect.Message
  • func (x *ActivationResp) Reset()
  • func (x *ActivationResp) String() string
• type MarbleClient
  • func NewMarbleClient(cc grpc.ClientConnInterface) MarbleClient
• type MarbleServer
• type Parameters
  • func (*Parameters) Descriptor() ([]byte, []int)
  • func (x *Parameters) GetArgv() []string
  • func (x *Parameters) GetEnv() map[string][]byte
  • func (x *Parameters) GetFiles() map[string][]byte
  • func (*Parameters) ProtoMessage()
  • func (x *Parameters) ProtoReflect() protoreflect.Message
  • func (x *Parameters) Reset()
  • func (x *Parameters) String() string
• type UnimplementedMarbleServer
  • func (UnimplementedMarbleServer) Activate(context.Context, *ActivationReq) (*ActivationResp, error)
• type UnsafeMarbleServer

Variables

var File_coordinator_proto protoreflect.FileDescriptor

var Marble_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.Marble",
	HandlerType: (*MarbleServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Activate",
			Handler:    _Marble_Activate_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "coordinator.proto",
}

Marble_ServiceDesc is the grpc.ServiceDesc for Marble service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMarbleServer

func RegisterMarbleServer(s grpc.ServiceRegistrar, srv MarbleServer)

Types

type ActivationReq

type ActivationReq struct {

	// TODO: sending the quote via metadata/context would be cleaner.
	Quote      []byte `protobuf:"bytes,1,opt,name=Quote,proto3" json:"Quote,omitempty"`
	CSR        []byte `protobuf:"bytes,2,opt,name=CSR,proto3" json:"CSR,omitempty"`
	MarbleType string `protobuf:"bytes,3,opt,name=MarbleType,proto3" json:"MarbleType,omitempty"`
	UUID       string `protobuf:"bytes,4,opt,name=UUID,proto3" json:"UUID,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivationReq) Descriptor

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

Deprecated: Use ActivationReq.ProtoReflect.Descriptor instead.

func (*ActivationReq) GetCSR

func (x *ActivationReq) GetCSR() []byte

func (*ActivationReq) GetMarbleType

func (x *ActivationReq) GetMarbleType() string

func (*ActivationReq) GetQuote

func (x *ActivationReq) GetQuote() []byte

func (*ActivationReq) GetUUID

func (x *ActivationReq) GetUUID() string

func (*ActivationReq) ProtoMessage

func (*ActivationReq) ProtoMessage()

func (*ActivationReq) ProtoReflect

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

func (*ActivationReq) Reset

func (x *ActivationReq) Reset()

func (*ActivationReq) String

func (x *ActivationReq) String() string

type ActivationResp

type ActivationResp struct {
	Parameters *Parameters `protobuf:"bytes,1,opt,name=Parameters,proto3" json:"Parameters,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivationResp) Descriptor

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

Deprecated: Use ActivationResp.ProtoReflect.Descriptor instead.

func (*ActivationResp) GetParameters

func (x *ActivationResp) GetParameters() *Parameters

func (*ActivationResp) ProtoMessage

func (*ActivationResp) ProtoMessage()

func (*ActivationResp) ProtoReflect

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

func (*ActivationResp) Reset

func (x *ActivationResp) Reset()

func (*ActivationResp) String

func (x *ActivationResp) String() string

type MarbleClient

type MarbleClient interface {
	// Activate activates a marble in the mesh.
	Activate(ctx context.Context, in *ActivationReq, opts ...grpc.CallOption) (*ActivationResp, error)
}

MarbleClient is the client API for Marble 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 NewMarbleClient

func NewMarbleClient(cc grpc.ClientConnInterface) MarbleClient

type MarbleServer

type MarbleServer interface {
	// Activate activates a marble in the mesh.
	Activate(context.Context, *ActivationReq) (*ActivationResp, error)
	// contains filtered or unexported methods
}

MarbleServer is the server API for Marble service. All implementations must embed UnimplementedMarbleServer for forward compatibility

type Parameters

type Parameters struct {
	Files map[string][]byte `` /* 151-byte string literal not displayed */
	Env   map[string][]byte `` /* 147-byte string literal not displayed */
	Argv  []string          `protobuf:"bytes,3,rep,name=Argv,proto3" json:"Argv,omitempty"`
	// contains filtered or unexported fields
}

func (*Parameters) Descriptor

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

Deprecated: Use Parameters.ProtoReflect.Descriptor instead.

func (*Parameters) GetArgv

func (x *Parameters) GetArgv() []string

func (*Parameters) GetEnv

func (x *Parameters) GetEnv() map[string][]byte

func (*Parameters) GetFiles

func (x *Parameters) GetFiles() map[string][]byte

func (*Parameters) ProtoMessage

func (*Parameters) ProtoMessage()

func (*Parameters) ProtoReflect

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

func (*Parameters) Reset

func (x *Parameters) Reset()

func (*Parameters) String

func (x *Parameters) String() string

type UnimplementedMarbleServer

type UnimplementedMarbleServer struct {
}

UnimplementedMarbleServer must be embedded to have forward compatible implementations.

func (UnimplementedMarbleServer) Activate

func (UnimplementedMarbleServer) Activate(context.Context, *ActivationReq) (*ActivationResp, error)

type UnsafeMarbleServer

type UnsafeMarbleServer interface {
	// contains filtered or unexported methods
}

UnsafeMarbleServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MarbleServer will result in compilation errors.