relay

package
v1.6.2 Latest Latest
Warning

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

 Go to latest Published: Aug 5, 2024 License: Apache-2.0 Imports: 8 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	DataTransfer_RequestState_FullMethodName    = "/relay.datatransfer.DataTransfer/RequestState"
	DataTransfer_SendState_FullMethodName       = "/relay.datatransfer.DataTransfer/SendState"
	DataTransfer_SendDriverState_FullMethodName = "/relay.datatransfer.DataTransfer/SendDriverState"
)
View Source 
const (
	EventSubscribe_SubscribeEvent_FullMethodName               = "/relay.events.EventSubscribe/SubscribeEvent"
	EventSubscribe_SendSubscriptionStatus_FullMethodName       = "/relay.events.EventSubscribe/SendSubscriptionStatus"
	EventSubscribe_SendDriverSubscriptionStatus_FullMethodName = "/relay.events.EventSubscribe/SendDriverSubscriptionStatus"
)
View Source 
const (
	EventPublish_SendDriverState_FullMethodName = "/relay.events.EventPublish/SendDriverState"
	EventPublish_SendState_FullMethodName       = "/relay.events.EventPublish/SendState"
)

Variables

View Source 
var DataTransfer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "relay.datatransfer.DataTransfer",
	HandlerType: (*DataTransferServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RequestState",
			Handler:    _DataTransfer_RequestState_Handler,
		},
		{
			MethodName: "SendState",
			Handler:    _DataTransfer_SendState_Handler,
		},
		{
			MethodName: "SendDriverState",
			Handler:    _DataTransfer_SendDriverState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relay/datatransfer.proto",
}

DataTransfer_ServiceDesc is the grpc.ServiceDesc for DataTransfer 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 EventPublish_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "relay.events.EventPublish",
	HandlerType: (*EventPublishServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendDriverState",
			Handler:    _EventPublish_SendDriverState_Handler,
		},
		{
			MethodName: "SendState",
			Handler:    _EventPublish_SendState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relay/events.proto",
}

EventPublish_ServiceDesc is the grpc.ServiceDesc for EventPublish 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 EventSubscribe_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "relay.events.EventSubscribe",
	HandlerType: (*EventSubscribeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SubscribeEvent",
			Handler:    _EventSubscribe_SubscribeEvent_Handler,
		},
		{
			MethodName: "SendSubscriptionStatus",
			Handler:    _EventSubscribe_SendSubscriptionStatus_Handler,
		},
		{
			MethodName: "SendDriverSubscriptionStatus",
			Handler:    _EventSubscribe_SendDriverSubscriptionStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relay/events.proto",
}

EventSubscribe_ServiceDesc is the grpc.ServiceDesc for EventSubscribe 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_relay_datatransfer_proto protoreflect.FileDescriptor
View Source 
var File_relay_events_proto protoreflect.FileDescriptor

Functions

func RegisterDataTransferServer 

func RegisterDataTransferServer(s grpc.ServiceRegistrar, srv DataTransferServer)

func RegisterEventPublishServer added in v1.5.0 

func RegisterEventPublishServer(s grpc.ServiceRegistrar, srv EventPublishServer)

func RegisterEventSubscribeServer added in v1.5.0 

func RegisterEventSubscribeServer(s grpc.ServiceRegistrar, srv EventSubscribeServer)

Types

type DataTransferClient 

type DataTransferClient interface {
	// the requesting relay sends a RequestState request to the remote relay with a
	// query defining the data it wants to receive
	RequestState(ctx context.Context, in *common.Query, opts ...grpc.CallOption) (*common.Ack, error)
	// the remote relay asynchronously sends back the requested data with
	// SendState
	SendState(ctx context.Context, in *common.ViewPayload, opts ...grpc.CallOption) (*common.Ack, error)
	// Handling state sent from the driver.
	SendDriverState(ctx context.Context, in *common.ViewPayload, opts ...grpc.CallOption) (*common.Ack, error)
}

DataTransferClient is the client API for DataTransfer 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 NewDataTransferClient 

func NewDataTransferClient(cc grpc.ClientConnInterface) DataTransferClient

type DataTransferServer 

type DataTransferServer interface {
	// the requesting relay sends a RequestState request to the remote relay with a
	// query defining the data it wants to receive
	RequestState(context.Context, *common.Query) (*common.Ack, error)
	// the remote relay asynchronously sends back the requested data with
	// SendState
	SendState(context.Context, *common.ViewPayload) (*common.Ack, error)
	// Handling state sent from the driver.
	SendDriverState(context.Context, *common.ViewPayload) (*common.Ack, error)
	// contains filtered or unexported methods
}

DataTransferServer is the server API for DataTransfer service. All implementations must embed UnimplementedDataTransferServer for forward compatibility

type EventPublishClient added in v1.5.0 

type EventPublishClient interface {
	// src-driver forwards the state as part of event subscription to src-relay
	SendDriverState(ctx context.Context, in *common.ViewPayload, opts ...grpc.CallOption) (*common.Ack, error)
	// src-relay will forward the state as part of event subscription to dest-relay
	SendState(ctx context.Context, in *common.ViewPayload, opts ...grpc.CallOption) (*common.Ack, error)
}

EventPublishClient is the client API for EventPublish 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 NewEventPublishClient added in v1.5.0 

func NewEventPublishClient(cc grpc.ClientConnInterface) EventPublishClient

type EventPublishServer added in v1.5.0 

type EventPublishServer interface {
	// src-driver forwards the state as part of event subscription to src-relay
	SendDriverState(context.Context, *common.ViewPayload) (*common.Ack, error)
	// src-relay will forward the state as part of event subscription to dest-relay
	SendState(context.Context, *common.ViewPayload) (*common.Ack, error)
	// contains filtered or unexported methods
}

EventPublishServer is the server API for EventPublish service. All implementations must embed UnimplementedEventPublishServer for forward compatibility

type EventSubscribeClient added in v1.5.0 

type EventSubscribeClient interface {
	// the dest-relay forwards the request from client as EventSubscription to the src-relay
	SubscribeEvent(ctx context.Context, in *common.EventSubscription, opts ...grpc.CallOption) (*common.Ack, error)
	// Src-relay based upon query (EventSubscription) forwards the same response (Ack)
	// from driver to the dest-relay by calling a new endpoint in dest-relay
	SendSubscriptionStatus(ctx context.Context, in *common.Ack, opts ...grpc.CallOption) (*common.Ack, error)
	// Src-driver status of event subscription (Ack)
	// to the src-relay by calling a new endpoint in src-relay
	SendDriverSubscriptionStatus(ctx context.Context, in *common.Ack, opts ...grpc.CallOption) (*common.Ack, error)
}

EventSubscribeClient is the client API for EventSubscribe 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 NewEventSubscribeClient added in v1.5.0 

func NewEventSubscribeClient(cc grpc.ClientConnInterface) EventSubscribeClient

type EventSubscribeServer added in v1.5.0 

type EventSubscribeServer interface {
	// the dest-relay forwards the request from client as EventSubscription to the src-relay
	SubscribeEvent(context.Context, *common.EventSubscription) (*common.Ack, error)
	// Src-relay based upon query (EventSubscription) forwards the same response (Ack)
	// from driver to the dest-relay by calling a new endpoint in dest-relay
	SendSubscriptionStatus(context.Context, *common.Ack) (*common.Ack, error)
	// Src-driver status of event subscription (Ack)
	// to the src-relay by calling a new endpoint in src-relay
	SendDriverSubscriptionStatus(context.Context, *common.Ack) (*common.Ack, error)
	// contains filtered or unexported methods
}

EventSubscribeServer is the server API for EventSubscribe service. All implementations must embed UnimplementedEventSubscribeServer for forward compatibility

type UnimplementedDataTransferServer 

type UnimplementedDataTransferServer struct {
}

UnimplementedDataTransferServer must be embedded to have forward compatible implementations.

func (UnimplementedDataTransferServer) RequestState 

func (UnimplementedDataTransferServer) RequestState(context.Context, *common.Query) (*common.Ack, error)

func (UnimplementedDataTransferServer) SendDriverState 

func (UnimplementedDataTransferServer) SendDriverState(context.Context, *common.ViewPayload) (*common.Ack, error)

func (UnimplementedDataTransferServer) SendState 

func (UnimplementedDataTransferServer) SendState(context.Context, *common.ViewPayload) (*common.Ack, error)

type UnimplementedEventPublishServer added in v1.5.0 

type UnimplementedEventPublishServer struct {
}

UnimplementedEventPublishServer must be embedded to have forward compatible implementations.

func (UnimplementedEventPublishServer) SendDriverState added in v1.5.0 

func (UnimplementedEventPublishServer) SendDriverState(context.Context, *common.ViewPayload) (*common.Ack, error)

func (UnimplementedEventPublishServer) SendState added in v1.5.0 

func (UnimplementedEventPublishServer) SendState(context.Context, *common.ViewPayload) (*common.Ack, error)

type UnimplementedEventSubscribeServer added in v1.5.0 

type UnimplementedEventSubscribeServer struct {
}

UnimplementedEventSubscribeServer must be embedded to have forward compatible implementations.

func (UnimplementedEventSubscribeServer) SendDriverSubscriptionStatus added in v1.5.0 

func (UnimplementedEventSubscribeServer) SendDriverSubscriptionStatus(context.Context, *common.Ack) (*common.Ack, error)

func (UnimplementedEventSubscribeServer) SendSubscriptionStatus added in v1.5.0 

func (UnimplementedEventSubscribeServer) SendSubscriptionStatus(context.Context, *common.Ack) (*common.Ack, error)

func (UnimplementedEventSubscribeServer) SubscribeEvent added in v1.5.0 

func (UnimplementedEventSubscribeServer) SubscribeEvent(context.Context, *common.EventSubscription) (*common.Ack, error)

type UnsafeDataTransferServer 

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

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

type UnsafeEventPublishServer added in v1.5.0 

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

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

type UnsafeEventSubscribeServer added in v1.5.0 

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

UnsafeEventSubscribeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventSubscribeServer 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.