federation

package
v0.0.0-...-9a3bd45 Latest Latest
Warning

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

 Go to latest Published: Mar 19, 2026 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Federation_Handshake_FullMethodName = "/federation.Federation/Handshake"
	Federation_Relay_FullMethodName     = "/federation.Federation/Relay"
)

Variables

View Source 
var Federation_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "federation.Federation",
	HandlerType: (*FederationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Handshake",
			Handler:    _Federation_Handshake_Handler,
		},
		{
			MethodName: "Relay",
			Handler:    _Federation_Relay_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "federation/federation.proto",
}

Federation_ServiceDesc is the grpc.ServiceDesc for Federation 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_federation_federation_proto protoreflect.FileDescriptor

Functions

func RegisterFederationServer 

func RegisterFederationServer(s grpc.ServiceRegistrar, srv FederationServer)

Types

type FederationClient 

type FederationClient interface {
	Handshake(ctx context.Context, in *HandshakeReq, opts ...grpc.CallOption) (*HandshakeAck, error)
	Relay(ctx context.Context, in *RelayPayload, opts ...grpc.CallOption) (*RelayAck, error)
}

FederationClient is the client API for Federation 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 NewFederationClient 

func NewFederationClient(cc grpc.ClientConnInterface) FederationClient

type FederationServer 

type FederationServer interface {
	Handshake(context.Context, *HandshakeReq) (*HandshakeAck, error)
	Relay(context.Context, *RelayPayload) (*RelayAck, error)
	// contains filtered or unexported methods
}

FederationServer is the server API for Federation service. All implementations must embed UnimplementedFederationServer for forward compatibility

type HandshakeAck 

type HandshakeAck struct {
	Ok       bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	ServerId string `protobuf:"bytes,2,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	Message  string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*HandshakeAck) Descriptor deprecated 

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

Deprecated: Use HandshakeAck.ProtoReflect.Descriptor instead.

func (*HandshakeAck) GetMessage 

func (x *HandshakeAck) GetMessage() string

func (*HandshakeAck) GetOk 

func (x *HandshakeAck) GetOk() bool

func (*HandshakeAck) GetServerId 

func (x *HandshakeAck) GetServerId() string

func (*HandshakeAck) ProtoMessage 

func (*HandshakeAck) ProtoMessage()

func (*HandshakeAck) ProtoReflect 

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

func (*HandshakeAck) Reset 

func (x *HandshakeAck) Reset()

func (*HandshakeAck) String 

func (x *HandshakeAck) String() string

type HandshakeReq 

type HandshakeReq struct {
	ServerId   string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	ServerName string `protobuf:"bytes,2,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
	// contains filtered or unexported fields
}

func (*HandshakeReq) Descriptor deprecated 

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

Deprecated: Use HandshakeReq.ProtoReflect.Descriptor instead.

func (*HandshakeReq) GetServerId 

func (x *HandshakeReq) GetServerId() string

func (*HandshakeReq) GetServerName 

func (x *HandshakeReq) GetServerName() string

func (*HandshakeReq) ProtoMessage 

func (*HandshakeReq) ProtoMessage()

func (*HandshakeReq) ProtoReflect 

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

func (*HandshakeReq) Reset 

func (x *HandshakeReq) Reset()

func (*HandshakeReq) String 

func (x *HandshakeReq) String() string

type RelayAck 

type RelayAck struct {
	EnvelopeId string `protobuf:"bytes,1,opt,name=envelope_id,json=envelopeId,proto3" json:"envelope_id,omitempty"`
	Accepted   bool   `protobuf:"varint,2,opt,name=accepted,proto3" json:"accepted,omitempty"`
	Info       string `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*RelayAck) Descriptor deprecated 

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

Deprecated: Use RelayAck.ProtoReflect.Descriptor instead.

func (*RelayAck) GetAccepted 

func (x *RelayAck) GetAccepted() bool

func (*RelayAck) GetEnvelopeId 

func (x *RelayAck) GetEnvelopeId() string

func (*RelayAck) GetInfo 

func (x *RelayAck) GetInfo() string

func (*RelayAck) ProtoMessage 

func (*RelayAck) ProtoMessage()

func (*RelayAck) ProtoReflect 

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

func (*RelayAck) Reset 

func (x *RelayAck) Reset()

func (*RelayAck) String 

func (x *RelayAck) String() string

type RelayPayload 

type RelayPayload struct {
	EnvelopeId   string                    `protobuf:"bytes,1,opt,name=envelope_id,json=envelopeId,proto3" json:"envelope_id,omitempty"`
	Sender       *common.UserAddress       `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	Recipient    *common.UserAddress       `protobuf:"bytes,3,opt,name=recipient,proto3" json:"recipient,omitempty"`
	OriginServer string                    `protobuf:"bytes,4,opt,name=origin_server,json=originServer,proto3" json:"origin_server,omitempty"`
	Payload      *common.EncryptedEnvelope `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	SentAt       *timestamppb.Timestamp    `protobuf:"bytes,6,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	// contains filtered or unexported fields
}

func (*RelayPayload) Descriptor deprecated 

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

Deprecated: Use RelayPayload.ProtoReflect.Descriptor instead.

func (*RelayPayload) GetEnvelopeId 

func (x *RelayPayload) GetEnvelopeId() string

func (*RelayPayload) GetOriginServer 

func (x *RelayPayload) GetOriginServer() string

func (*RelayPayload) GetPayload 

func (x *RelayPayload) GetPayload() *common.EncryptedEnvelope

func (*RelayPayload) GetRecipient 

func (x *RelayPayload) GetRecipient() *common.UserAddress

func (*RelayPayload) GetSender 

func (x *RelayPayload) GetSender() *common.UserAddress

func (*RelayPayload) GetSentAt 

func (x *RelayPayload) GetSentAt() *timestamppb.Timestamp

func (*RelayPayload) ProtoMessage 

func (*RelayPayload) ProtoMessage()

func (*RelayPayload) ProtoReflect 

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

func (*RelayPayload) Reset 

func (x *RelayPayload) Reset()

func (*RelayPayload) String 

func (x *RelayPayload) String() string

type UnimplementedFederationServer 

type UnimplementedFederationServer struct {
}

UnimplementedFederationServer must be embedded to have forward compatible implementations.

func (UnimplementedFederationServer) Handshake 

func (UnimplementedFederationServer) Handshake(context.Context, *HandshakeReq) (*HandshakeAck, error)

func (UnimplementedFederationServer) Relay 

func (UnimplementedFederationServer) Relay(context.Context, *RelayPayload) (*RelayAck, error)

type UnsafeFederationServer 

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

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