pb

package
Version: v0.0.0-...-079dddc Latest Latest
Warning

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

Go to latest
Published: Sep 10, 2021 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ControlService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mindmeld.ControlService",
	HandlerType: (*ControlServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ForwardToService",
			Handler:    _ControlService_ForwardToService_Handler,
		},
		{
			MethodName: "ListServices",
			Handler:    _ControlService_ListServices_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CreateService",
			Handler:       _ControlService_CreateService_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "mindmeld.proto",
}

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

View Source
var File_mindmeld_proto protoreflect.FileDescriptor
View Source
var ProxyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mindmeld.ProxyService",
	HandlerType: (*ProxyServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ProxyConnection",
			Handler:       _ProxyService_ProxyConnection_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "mindmeld.proto",
}

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

Functions

func RegisterControlServiceServer

func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)

func RegisterProxyServiceServer

func RegisterProxyServiceServer(s grpc.ServiceRegistrar, srv ProxyServiceServer)

Types

type ControlServiceClient

type ControlServiceClient interface {
	// Create a service, and wait for requests to come through via the stream.
	// The caller will then receive a response message for each client that wants
	// to connect to the service.
	CreateService(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (ControlService_CreateServiceClient, error)
	// Forward to remote service.
	ForwardToService(ctx context.Context, in *ForwardToServiceRequest, opts ...grpc.CallOption) (*ForwardToServiceResponse, error)
	// List services.
	ListServices(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesResponse, error)
}

ControlServiceClient is the client API for ControlService 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.

type ControlServiceServer

type ControlServiceServer interface {
	// Create a service, and wait for requests to come through via the stream.
	// The caller will then receive a response message for each client that wants
	// to connect to the service.
	CreateService(*CreateServiceRequest, ControlService_CreateServiceServer) error
	// Forward to remote service.
	ForwardToService(context.Context, *ForwardToServiceRequest) (*ForwardToServiceResponse, error)
	// List services.
	ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
	// contains filtered or unexported methods
}

ControlServiceServer is the server API for ControlService service. All implementations must embed UnimplementedControlServiceServer for forward compatibility

type ControlService_CreateServiceClient

type ControlService_CreateServiceClient interface {
	Recv() (*CreateServiceResponse, error)
	grpc.ClientStream
}

type ControlService_CreateServiceServer

type ControlService_CreateServiceServer interface {
	Send(*CreateServiceResponse) error
	grpc.ServerStream
}

type CreateServiceRequest

type CreateServiceRequest struct {

	// Name of the service.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Create a service hosted by this member.

func (*CreateServiceRequest) Descriptor deprecated

This method has been deprecated.
func (*CreateServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateServiceRequest.ProtoReflect.Descriptor instead.

func (*CreateServiceRequest) GetName

func (x *CreateServiceRequest) GetName() string

func (*CreateServiceRequest) ProtoMessage

func (*CreateServiceRequest) ProtoMessage()

func (*CreateServiceRequest) ProtoReflect

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

func (*CreateServiceRequest) Reset

func (x *CreateServiceRequest) Reset()

func (*CreateServiceRequest) String

func (x *CreateServiceRequest) String() string

type CreateServiceResponse

type CreateServiceResponse struct {

	// Token to use when using this service.
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// Dial address for the proxy.
	DialAddr string `protobuf:"bytes,2,opt,name=dial_addr,json=dialAddr,proto3" json:"dial_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateServiceResponse) Descriptor deprecated

This method has been deprecated.
func (*CreateServiceResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateServiceResponse.ProtoReflect.Descriptor instead.

func (*CreateServiceResponse) GetDialAddr

func (x *CreateServiceResponse) GetDialAddr() string

func (*CreateServiceResponse) GetToken

func (x *CreateServiceResponse) GetToken() string

func (*CreateServiceResponse) ProtoMessage

func (*CreateServiceResponse) ProtoMessage()

func (*CreateServiceResponse) ProtoReflect

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

func (*CreateServiceResponse) Reset

func (x *CreateServiceResponse) Reset()

func (*CreateServiceResponse) String

func (x *CreateServiceResponse) String() string

type ForwardToServiceRequest

type ForwardToServiceRequest struct {

	// Name of the service.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Forward a service from this member to another.

func (*ForwardToServiceRequest) Descriptor deprecated

This method has been deprecated.
func (*ForwardToServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ForwardToServiceRequest.ProtoReflect.Descriptor instead.

func (*ForwardToServiceRequest) GetName

func (x *ForwardToServiceRequest) GetName() string

func (*ForwardToServiceRequest) ProtoMessage

func (*ForwardToServiceRequest) ProtoMessage()

func (*ForwardToServiceRequest) ProtoReflect

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

func (*ForwardToServiceRequest) Reset

func (x *ForwardToServiceRequest) Reset()

func (*ForwardToServiceRequest) String

func (x *ForwardToServiceRequest) String() string

type ForwardToServiceResponse

type ForwardToServiceResponse struct {

	// Token to use when using this service.
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// Dial address for the proxy.
	DialAddr string `protobuf:"bytes,2,opt,name=dial_addr,json=dialAddr,proto3" json:"dial_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardToServiceResponse) Descriptor deprecated

This method has been deprecated.
func (*ForwardToServiceResponse) Descriptor() ([]byte, []int)

Deprecated: Use ForwardToServiceResponse.ProtoReflect.Descriptor instead.

func (*ForwardToServiceResponse) GetDialAddr

func (x *ForwardToServiceResponse) GetDialAddr() string

func (*ForwardToServiceResponse) GetToken

func (x *ForwardToServiceResponse) GetToken() string

func (*ForwardToServiceResponse) ProtoMessage

func (*ForwardToServiceResponse) ProtoMessage()

func (*ForwardToServiceResponse) ProtoReflect

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

func (*ForwardToServiceResponse) Reset

func (x *ForwardToServiceResponse) Reset()

func (*ForwardToServiceResponse) String

func (x *ForwardToServiceResponse) String() string
type Header struct {

	// Token to use to access the service.
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated

This method has been deprecated.
func (*Header) Descriptor() ([]byte, []int)

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetToken

func (x *Header) GetToken() string

func (*Header) ProtoMessage

func (*Header) ProtoMessage()

func (*Header) ProtoReflect

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

func (*Header) Reset

func (x *Header) Reset()

func (*Header) String

func (x *Header) String() string

type ListServicesRequest

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

func (*ListServicesRequest) Descriptor deprecated

This method has been deprecated.
func (*ListServicesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListServicesRequest.ProtoReflect.Descriptor instead.

func (*ListServicesRequest) ProtoMessage

func (*ListServicesRequest) ProtoMessage()

func (*ListServicesRequest) ProtoReflect

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

func (*ListServicesRequest) Reset

func (x *ListServicesRequest) Reset()

func (*ListServicesRequest) String

func (x *ListServicesRequest) String() string

type ListServicesResponse

type ListServicesResponse struct {
	Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*ListServicesResponse) Descriptor deprecated

This method has been deprecated.
func (*ListServicesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListServicesResponse.ProtoReflect.Descriptor instead.

func (*ListServicesResponse) GetServices

func (x *ListServicesResponse) GetServices() []*Service

func (*ListServicesResponse) ProtoMessage

func (*ListServicesResponse) ProtoMessage()

func (*ListServicesResponse) ProtoReflect

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

func (*ListServicesResponse) Reset

func (x *ListServicesResponse) Reset()

func (*ListServicesResponse) String

func (x *ListServicesResponse) String() string

type Payload

type Payload struct {

	// Types that are assignable to Payload:
	//	*Payload_Header
	//	*Payload_Data
	Payload isPayload_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*Payload) Descriptor deprecated

This method has been deprecated.
func (*Payload) Descriptor() ([]byte, []int)

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetData

func (x *Payload) GetData() []byte

func (*Payload) GetHeader

func (x *Payload) GetHeader() *Header

func (*Payload) GetPayload

func (m *Payload) GetPayload() isPayload_Payload

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) ProtoReflect

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

func (*Payload) Reset

func (x *Payload) Reset()

func (*Payload) String

func (x *Payload) String() string

type Payload_Data

type Payload_Data struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type Payload_Header

type Payload_Header struct {
	Header *Header `protobuf:"bytes,1,opt,name=header,proto3,oneof"`
}

type ProxyServiceClient

type ProxyServiceClient interface {
	ProxyConnection(ctx context.Context, opts ...grpc.CallOption) (ProxyService_ProxyConnectionClient, error)
}

ProxyServiceClient is the client API for ProxyService 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.

type ProxyServiceServer

type ProxyServiceServer interface {
	ProxyConnection(ProxyService_ProxyConnectionServer) error
	// contains filtered or unexported methods
}

ProxyServiceServer is the server API for ProxyService service. All implementations must embed UnimplementedProxyServiceServer for forward compatibility

type ProxyService_ProxyConnectionClient

type ProxyService_ProxyConnectionClient interface {
	Send(*Payload) error
	Recv() (*Payload, error)
	grpc.ClientStream
}

type ProxyService_ProxyConnectionServer

type ProxyService_ProxyConnectionServer interface {
	Send(*Payload) error
	Recv() (*Payload, error)
	grpc.ServerStream
}

type Service

type Service struct {

	// Name of the service.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Time the service was created.  Output only.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Service) Descriptor deprecated

This method has been deprecated.
func (*Service) Descriptor() ([]byte, []int)

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetCreateTime

func (x *Service) GetCreateTime() *timestamppb.Timestamp

func (*Service) GetName

func (x *Service) GetName() string

func (*Service) ProtoMessage

func (*Service) ProtoMessage()

func (*Service) ProtoReflect

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

func (*Service) Reset

func (x *Service) Reset()

func (*Service) String

func (x *Service) String() string

type UnimplementedControlServiceServer

type UnimplementedControlServiceServer struct {
}

UnimplementedControlServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedControlServiceServer) CreateService

func (UnimplementedControlServiceServer) ForwardToService

func (UnimplementedControlServiceServer) ListServices

type UnimplementedProxyServiceServer

type UnimplementedProxyServiceServer struct {
}

UnimplementedProxyServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProxyServiceServer) ProxyConnection

type UnsafeControlServiceServer

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

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

type UnsafeProxyServiceServer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL