pb

package
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.

func NewControlServiceClient 

func NewControlServiceClient(cc grpc.ClientConnInterface) ControlServiceClient

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 

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 

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 

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 

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 

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 

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 

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 

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.

func NewProxyServiceClient 

func NewProxyServiceClient(cc grpc.ClientConnInterface) ProxyServiceClient

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 

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) CreateService(*CreateServiceRequest, ControlService_CreateServiceServer) error

func (UnimplementedControlServiceServer) ForwardToService 

func (UnimplementedControlServiceServer) ForwardToService(context.Context, *ForwardToServiceRequest) (*ForwardToServiceResponse, error)

func (UnimplementedControlServiceServer) ListServices 

func (UnimplementedControlServiceServer) ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)

type UnimplementedProxyServiceServer 

type UnimplementedProxyServiceServer struct {
}

UnimplementedProxyServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProxyServiceServer) ProxyConnection 

func (UnimplementedProxyServiceServer) ProxyConnection(ProxyService_ProxyConnectionServer) error

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.

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.