pb

package
v1.0.4 Latest Latest
Warning

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

 Go to latest Published: Dec 9, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pb_scoutHub_proto protoreflect.FileDescriptor
View Source 
var ScoutHub_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "contentpubsub.pb.ScoutHub",
	HandlerType: (*ScoutHubServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Subscribe",
			Handler:    _ScoutHub_Subscribe_Handler,
		},
		{
			MethodName: "Publish",
			Handler:    _ScoutHub_Publish_Handler,
		},
		{
			MethodName: "Notify",
			Handler:    _ScoutHub_Notify_Handler,
		},
		{
			MethodName: "UpdateBackup",
			Handler:    _ScoutHub_UpdateBackup_Handler,
		},
		{
			MethodName: "LogToTracker",
			Handler:    _ScoutHub_LogToTracker_Handler,
		},
		{
			MethodName: "AckToTracker",
			Handler:    _ScoutHub_AckToTracker_Handler,
		},
		{
			MethodName: "TrackerRefresh",
			Handler:    _ScoutHub_TrackerRefresh_Handler,
		},
		{
			MethodName: "AckUp",
			Handler:    _ScoutHub_AckUp_Handler,
		},
		{
			MethodName: "AckOp",
			Handler:    _ScoutHub_AckOp_Handler,
		},
		{
			MethodName: "HelpNewRv",
			Handler:    _ScoutHub_HelpNewRv_Handler,
		},
		{
			MethodName: "AdvertiseGroup",
			Handler:    _ScoutHub_AdvertiseGroup_Handler,
		},
		{
			MethodName: "GroupSearchRequest",
			Handler:    _ScoutHub_GroupSearchRequest_Handler,
		},
		{
			MethodName: "PremiumSubscribe",
			Handler:    _ScoutHub_PremiumSubscribe_Handler,
		},
		{
			MethodName: "PremiumUnsubscribe",
			Handler:    _ScoutHub_PremiumUnsubscribe_Handler,
		},
		{
			MethodName: "PremiumPublish",
			Handler:    _ScoutHub_PremiumPublish_Handler,
		},
		{
			MethodName: "RequestHelp",
			Handler:    _ScoutHub_RequestHelp_Handler,
		},
		{
			MethodName: "DelegateSubToHelper",
			Handler:    _ScoutHub_DelegateSubToHelper_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "BackupRefresh",
			Handler:       _ScoutHub_BackupRefresh_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "pb/scoutHub.proto",
}

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

Functions

func RegisterScoutHubServer 

func RegisterScoutHubServer(s grpc.ServiceRegistrar, srv ScoutHubServer)

Types

type Ack 

type Ack struct {
	State bool   `protobuf:"varint,1,opt,name=state,proto3" json:"state,omitempty"`
	Info  string `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	Op    string `protobuf:"bytes,3,opt,name=op,proto3" json:"op,omitempty"`
	// contains filtered or unexported fields
}

func (*Ack) Descriptor deprecated 

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

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetInfo 

func (x *Ack) GetInfo() string

func (*Ack) GetOp 

func (x *Ack) GetOp() string

func (*Ack) GetState 

func (x *Ack) GetState() bool

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect 

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

func (*Ack) Reset 

func (x *Ack) Reset()

func (*Ack) String 

func (x *Ack) String() string

type AdvertRequest 

type AdvertRequest struct {
	GroupID *MulticastGroupID `protobuf:"bytes,1,opt,name=groupID,proto3" json:"groupID,omitempty"`
	RvId    string            `protobuf:"bytes,2,opt,name=rvId,proto3" json:"rvId,omitempty"`
	// contains filtered or unexported fields
}

func (*AdvertRequest) Descriptor deprecated 

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

Deprecated: Use AdvertRequest.ProtoReflect.Descriptor instead.

func (*AdvertRequest) GetGroupID 

func (x *AdvertRequest) GetGroupID() *MulticastGroupID

func (*AdvertRequest) GetRvId 

func (x *AdvertRequest) GetRvId() string

func (*AdvertRequest) ProtoMessage 

func (*AdvertRequest) ProtoMessage()

func (*AdvertRequest) ProtoReflect 

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

func (*AdvertRequest) Reset 

func (x *AdvertRequest) Reset()

func (*AdvertRequest) String 

func (x *AdvertRequest) String() string

type DelegateSub 

type DelegateSub struct {
	GroupID *MulticastGroupID `protobuf:"bytes,1,opt,name=groupID,proto3" json:"groupID,omitempty"`
	Sub     *MinimalSubData   `protobuf:"bytes,2,opt,name=sub,proto3" json:"sub,omitempty"`
	// contains filtered or unexported fields
}

func (*DelegateSub) Descriptor deprecated 

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

Deprecated: Use DelegateSub.ProtoReflect.Descriptor instead.

func (*DelegateSub) GetGroupID 

func (x *DelegateSub) GetGroupID() *MulticastGroupID

func (*DelegateSub) GetSub 

func (x *DelegateSub) GetSub() *MinimalSubData

func (*DelegateSub) ProtoMessage 

func (*DelegateSub) ProtoMessage()

func (*DelegateSub) ProtoReflect 

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

func (*DelegateSub) Reset 

func (x *DelegateSub) Reset()

func (*DelegateSub) String 

func (x *DelegateSub) String() string

type Event 

type Event struct {
	EventID       *EventID `protobuf:"bytes,1,opt,name=eventID,proto3" json:"eventID,omitempty"`
	Predicate     string   `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
	RvId          string   `protobuf:"bytes,3,opt,name=rvId,proto3" json:"rvId,omitempty"`
	Event         string   `protobuf:"bytes,4,opt,name=event,proto3" json:"event,omitempty"`
	LastHop       string   `protobuf:"bytes,5,opt,name=lastHop,proto3" json:"lastHop,omitempty"`
	AckAddr       string   `protobuf:"bytes,6,opt,name=ackAddr,proto3" json:"ackAddr,omitempty"`
	Backup        bool     `protobuf:"varint,7,opt,name=backup,proto3" json:"backup,omitempty"`
	OriginalRoute string   `protobuf:"bytes,8,opt,name=originalRoute,proto3" json:"originalRoute,omitempty"`
	BirthTime     string   `protobuf:"bytes,9,opt,name=birthTime,proto3" json:"birthTime,omitempty"`
	PubAddr       string   `protobuf:"bytes,10,opt,name=pubAddr,proto3" json:"pubAddr,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAckAddr 

func (x *Event) GetAckAddr() string

func (*Event) GetBackup 

func (x *Event) GetBackup() bool

func (*Event) GetBirthTime 

func (x *Event) GetBirthTime() string

func (*Event) GetEvent 

func (x *Event) GetEvent() string

func (*Event) GetEventID 

func (x *Event) GetEventID() *EventID

func (*Event) GetLastHop 

func (x *Event) GetLastHop() string

func (*Event) GetOriginalRoute 

func (x *Event) GetOriginalRoute() string

func (*Event) GetPredicate 

func (x *Event) GetPredicate() string

func (*Event) GetPubAddr 

func (x *Event) GetPubAddr() string

func (*Event) GetRvId 

func (x *Event) GetRvId() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventAck 

type EventAck struct {
	RvID           string                 `protobuf:"bytes,1,opt,name=rvID,proto3" json:"rvID,omitempty"`
	EventID        *EventID               `protobuf:"bytes,2,opt,name=eventID,proto3" json:"eventID,omitempty"`
	PeerID         string                 `protobuf:"bytes,3,opt,name=peerID,proto3" json:"peerID,omitempty"`
	RecruitMessage *RecruitTrackerMessage `protobuf:"bytes,4,opt,name=recruitMessage,proto3" json:"recruitMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*EventAck) Descriptor deprecated 

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

Deprecated: Use EventAck.ProtoReflect.Descriptor instead.

func (*EventAck) GetEventID 

func (x *EventAck) GetEventID() *EventID

func (*EventAck) GetPeerID 

func (x *EventAck) GetPeerID() string

func (*EventAck) GetRecruitMessage 

func (x *EventAck) GetRecruitMessage() *RecruitTrackerMessage

func (*EventAck) GetRvID 

func (x *EventAck) GetRvID() string

func (*EventAck) ProtoMessage 

func (*EventAck) ProtoMessage()

func (*EventAck) ProtoReflect 

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

func (*EventAck) Reset 

func (x *EventAck) Reset()

func (*EventAck) String 

func (x *EventAck) String() string

type EventID 

type EventID struct {
	PublisherID   string `protobuf:"bytes,1,opt,name=publisherID,proto3" json:"publisherID,omitempty"`
	SessionNumber int32  `protobuf:"varint,2,opt,name=sessionNumber,proto3" json:"sessionNumber,omitempty"`
	SeqID         int32  `protobuf:"varint,3,opt,name=seqID,proto3" json:"seqID,omitempty"`
	// contains filtered or unexported fields
}

func (*EventID) Descriptor deprecated 

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

Deprecated: Use EventID.ProtoReflect.Descriptor instead.

func (*EventID) GetPublisherID 

func (x *EventID) GetPublisherID() string

func (*EventID) GetSeqID 

func (x *EventID) GetSeqID() int32

func (*EventID) GetSessionNumber 

func (x *EventID) GetSessionNumber() int32

func (*EventID) ProtoMessage 

func (*EventID) ProtoMessage()

func (*EventID) ProtoReflect 

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

func (*EventID) Reset 

func (x *EventID) Reset()

func (*EventID) String 

func (x *EventID) String() string

type EventLog 

type EventLog struct {
	RvID           string                 `protobuf:"bytes,1,opt,name=rvID,proto3" json:"rvID,omitempty"`
	EventID        *EventID               `protobuf:"bytes,2,opt,name=eventID,proto3" json:"eventID,omitempty"`
	Event          *Event                 `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	Log            map[string]bool        `` /* 148-byte string literal not displayed */
	RecruitMessage *RecruitTrackerMessage `protobuf:"bytes,5,opt,name=recruitMessage,proto3" json:"recruitMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*EventLog) Descriptor deprecated 

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

Deprecated: Use EventLog.ProtoReflect.Descriptor instead.

func (*EventLog) GetEvent 

func (x *EventLog) GetEvent() *Event

func (*EventLog) GetEventID 

func (x *EventLog) GetEventID() *EventID

func (*EventLog) GetLog 

func (x *EventLog) GetLog() map[string]bool

func (*EventLog) GetRecruitMessage 

func (x *EventLog) GetRecruitMessage() *RecruitTrackerMessage

func (*EventLog) GetRvID 

func (x *EventLog) GetRvID() string

func (*EventLog) ProtoMessage 

func (*EventLog) ProtoMessage()

func (*EventLog) ProtoReflect 

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

func (*EventLog) Reset 

func (x *EventLog) Reset()

func (*EventLog) String 

func (x *EventLog) String() string

type HelpRequest 

type HelpRequest struct {
	GroupID *MulticastGroupID         `protobuf:"bytes,1,opt,name=groupID,proto3" json:"groupID,omitempty"`
	Subs    map[int32]*MinimalSubData `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*HelpRequest) Descriptor deprecated 

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

Deprecated: Use HelpRequest.ProtoReflect.Descriptor instead.

func (*HelpRequest) GetGroupID 

func (x *HelpRequest) GetGroupID() *MulticastGroupID

func (*HelpRequest) GetSubs 

func (x *HelpRequest) GetSubs() map[int32]*MinimalSubData

func (*HelpRequest) ProtoMessage 

func (*HelpRequest) ProtoMessage()

func (*HelpRequest) ProtoReflect 

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

func (*HelpRequest) Reset 

func (x *HelpRequest) Reset()

func (*HelpRequest) String 

func (x *HelpRequest) String() string

type MinimalSubData 

type MinimalSubData struct {
	Predicate string `protobuf:"bytes,1,opt,name=predicate,proto3" json:"predicate,omitempty"`
	Addr      string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*MinimalSubData) Descriptor deprecated 

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

Deprecated: Use MinimalSubData.ProtoReflect.Descriptor instead.

func (*MinimalSubData) GetAddr 

func (x *MinimalSubData) GetAddr() string

func (*MinimalSubData) GetPredicate 

func (x *MinimalSubData) GetPredicate() string

func (*MinimalSubData) ProtoMessage 

func (*MinimalSubData) ProtoMessage()

func (*MinimalSubData) ProtoReflect 

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

func (*MinimalSubData) Reset 

func (x *MinimalSubData) Reset()

func (*MinimalSubData) String 

func (x *MinimalSubData) String() string

type MulticastGroupID 

type MulticastGroupID struct {
	OwnerAddr string `protobuf:"bytes,1,opt,name=ownerAddr,proto3" json:"ownerAddr,omitempty"`
	Predicate string `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
	// contains filtered or unexported fields
}

func (*MulticastGroupID) Descriptor deprecated 

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

Deprecated: Use MulticastGroupID.ProtoReflect.Descriptor instead.

func (*MulticastGroupID) GetOwnerAddr 

func (x *MulticastGroupID) GetOwnerAddr() string

func (*MulticastGroupID) GetPredicate 

func (x *MulticastGroupID) GetPredicate() string

func (*MulticastGroupID) ProtoMessage 

func (*MulticastGroupID) ProtoMessage()

func (*MulticastGroupID) ProtoReflect 

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

func (*MulticastGroupID) Reset 

func (x *MulticastGroupID) Reset()

func (*MulticastGroupID) String 

func (x *MulticastGroupID) String() string

type PremiumEvent 

type PremiumEvent struct {
	GroupID   *MulticastGroupID `protobuf:"bytes,1,opt,name=groupID,proto3" json:"groupID,omitempty"`
	Event     string            `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	EventPred string            `protobuf:"bytes,3,opt,name=eventPred,proto3" json:"eventPred,omitempty"`
	BirthTime string            `protobuf:"bytes,4,opt,name=birthTime,proto3" json:"birthTime,omitempty"`
	// contains filtered or unexported fields
}

func (*PremiumEvent) Descriptor deprecated 

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

Deprecated: Use PremiumEvent.ProtoReflect.Descriptor instead.

func (*PremiumEvent) GetBirthTime 

func (x *PremiumEvent) GetBirthTime() string

func (*PremiumEvent) GetEvent 

func (x *PremiumEvent) GetEvent() string

func (*PremiumEvent) GetEventPred 

func (x *PremiumEvent) GetEventPred() string

func (*PremiumEvent) GetGroupID 

func (x *PremiumEvent) GetGroupID() *MulticastGroupID

func (*PremiumEvent) ProtoMessage 

func (*PremiumEvent) ProtoMessage()

func (*PremiumEvent) ProtoReflect 

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

func (*PremiumEvent) Reset 

func (x *PremiumEvent) Reset()

func (*PremiumEvent) String 

func (x *PremiumEvent) String() string

type PremiumSubscription 

type PremiumSubscription struct {
	Addr         string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Cap          int32  `protobuf:"varint,2,opt,name=cap,proto3" json:"cap,omitempty"`
	Region       string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	OwnPredicate string `protobuf:"bytes,4,opt,name=ownPredicate,proto3" json:"ownPredicate,omitempty"`
	PubPredicate string `protobuf:"bytes,5,opt,name=pubPredicate,proto3" json:"pubPredicate,omitempty"`
	// contains filtered or unexported fields
}

func (*PremiumSubscription) Descriptor deprecated 

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

Deprecated: Use PremiumSubscription.ProtoReflect.Descriptor instead.

func (*PremiumSubscription) GetAddr 

func (x *PremiumSubscription) GetAddr() string

func (*PremiumSubscription) GetCap 

func (x *PremiumSubscription) GetCap() int32

func (*PremiumSubscription) GetOwnPredicate 

func (x *PremiumSubscription) GetOwnPredicate() string

func (*PremiumSubscription) GetPubPredicate 

func (x *PremiumSubscription) GetPubPredicate() string

func (*PremiumSubscription) GetRegion 

func (x *PremiumSubscription) GetRegion() string

func (*PremiumSubscription) ProtoMessage 

func (*PremiumSubscription) ProtoMessage()

func (*PremiumSubscription) ProtoReflect 

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

func (*PremiumSubscription) Reset 

func (x *PremiumSubscription) Reset()

func (*PremiumSubscription) String 

func (x *PremiumSubscription) String() string

type RecruitTrackerMessage 

type RecruitTrackerMessage struct {
	Leader bool   `protobuf:"varint,1,opt,name=leader,proto3" json:"leader,omitempty"`
	RvID   string `protobuf:"bytes,2,opt,name=rvID,proto3" json:"rvID,omitempty"`
	RvAddr string `protobuf:"bytes,3,opt,name=rvAddr,proto3" json:"rvAddr,omitempty"`
	// contains filtered or unexported fields
}

func (*RecruitTrackerMessage) Descriptor deprecated 

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

Deprecated: Use RecruitTrackerMessage.ProtoReflect.Descriptor instead.

func (*RecruitTrackerMessage) GetLeader 

func (x *RecruitTrackerMessage) GetLeader() bool

func (*RecruitTrackerMessage) GetRvAddr 

func (x *RecruitTrackerMessage) GetRvAddr() string

func (*RecruitTrackerMessage) GetRvID 

func (x *RecruitTrackerMessage) GetRvID() string

func (*RecruitTrackerMessage) ProtoMessage 

func (*RecruitTrackerMessage) ProtoMessage()

func (*RecruitTrackerMessage) ProtoReflect 

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

func (*RecruitTrackerMessage) Reset 

func (x *RecruitTrackerMessage) Reset()

func (*RecruitTrackerMessage) String 

func (x *RecruitTrackerMessage) String() string

type RefreshTracker 

type RefreshTracker struct {
	Logs map[string]*EventLog `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RefreshTracker) Descriptor deprecated 

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

Deprecated: Use RefreshTracker.ProtoReflect.Descriptor instead.

func (*RefreshTracker) GetLogs 

func (x *RefreshTracker) GetLogs() map[string]*EventLog

func (*RefreshTracker) ProtoMessage 

func (*RefreshTracker) ProtoMessage()

func (*RefreshTracker) ProtoReflect 

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

func (*RefreshTracker) Reset 

func (x *RefreshTracker) Reset()

func (*RefreshTracker) String 

func (x *RefreshTracker) String() string

type ScoutHubClient 

type ScoutHubClient interface {
	// ScoutSubs
	Subscribe(ctx context.Context, in *Subscription, opts ...grpc.CallOption) (*Ack, error)
	Publish(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Ack, error)
	Notify(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Ack, error)
	UpdateBackup(ctx context.Context, in *Update, opts ...grpc.CallOption) (*Ack, error)
	BackupRefresh(ctx context.Context, opts ...grpc.CallOption) (ScoutHub_BackupRefreshClient, error)
	LogToTracker(ctx context.Context, in *EventLog, opts ...grpc.CallOption) (*Ack, error)
	AckToTracker(ctx context.Context, in *EventAck, opts ...grpc.CallOption) (*Ack, error)
	TrackerRefresh(ctx context.Context, in *RecruitTrackerMessage, opts ...grpc.CallOption) (*Ack, error)
	AckUp(ctx context.Context, in *EventAck, opts ...grpc.CallOption) (*Ack, error)
	AckOp(ctx context.Context, in *Ack, opts ...grpc.CallOption) (*Ack, error)
	HelpNewRv(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Ack, error)
	// FastDelivery
	AdvertiseGroup(ctx context.Context, in *AdvertRequest, opts ...grpc.CallOption) (*Ack, error)
	GroupSearchRequest(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchReply, error)
	PremiumSubscribe(ctx context.Context, in *PremiumSubscription, opts ...grpc.CallOption) (*Ack, error)
	PremiumUnsubscribe(ctx context.Context, in *PremiumSubscription, opts ...grpc.CallOption) (*Ack, error)
	PremiumPublish(ctx context.Context, in *PremiumEvent, opts ...grpc.CallOption) (*Ack, error)
	RequestHelp(ctx context.Context, in *HelpRequest, opts ...grpc.CallOption) (*Ack, error)
	DelegateSubToHelper(ctx context.Context, in *DelegateSub, opts ...grpc.CallOption) (*Ack, error)
}

ScoutHubClient is the client API for ScoutHub 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 NewScoutHubClient 

func NewScoutHubClient(cc grpc.ClientConnInterface) ScoutHubClient

type ScoutHubServer 

type ScoutHubServer interface {
	// ScoutSubs
	Subscribe(context.Context, *Subscription) (*Ack, error)
	Publish(context.Context, *Event) (*Ack, error)
	Notify(context.Context, *Event) (*Ack, error)
	UpdateBackup(context.Context, *Update) (*Ack, error)
	BackupRefresh(ScoutHub_BackupRefreshServer) error
	LogToTracker(context.Context, *EventLog) (*Ack, error)
	AckToTracker(context.Context, *EventAck) (*Ack, error)
	TrackerRefresh(context.Context, *RecruitTrackerMessage) (*Ack, error)
	AckUp(context.Context, *EventAck) (*Ack, error)
	AckOp(context.Context, *Ack) (*Ack, error)
	HelpNewRv(context.Context, *Event) (*Ack, error)
	// FastDelivery
	AdvertiseGroup(context.Context, *AdvertRequest) (*Ack, error)
	GroupSearchRequest(context.Context, *SearchRequest) (*SearchReply, error)
	PremiumSubscribe(context.Context, *PremiumSubscription) (*Ack, error)
	PremiumUnsubscribe(context.Context, *PremiumSubscription) (*Ack, error)
	PremiumPublish(context.Context, *PremiumEvent) (*Ack, error)
	RequestHelp(context.Context, *HelpRequest) (*Ack, error)
	DelegateSubToHelper(context.Context, *DelegateSub) (*Ack, error)
	// contains filtered or unexported methods
}

ScoutHubServer is the server API for ScoutHub service. All implementations must embed UnimplementedScoutHubServer for forward compatibility

type ScoutHub_BackupRefreshClient 

type ScoutHub_BackupRefreshClient interface {
	Send(*Update) error
	CloseAndRecv() (*Ack, error)
	grpc.ClientStream
}

type ScoutHub_BackupRefreshServer 

type ScoutHub_BackupRefreshServer interface {
	SendAndClose(*Ack) error
	Recv() (*Update, error)
	grpc.ServerStream
}

type SearchReply 

type SearchReply struct {
	Groups map[int32]*MulticastGroupID `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SearchReply) Descriptor deprecated 

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

Deprecated: Use SearchReply.ProtoReflect.Descriptor instead.

func (*SearchReply) GetGroups 

func (x *SearchReply) GetGroups() map[int32]*MulticastGroupID

func (*SearchReply) ProtoMessage 

func (*SearchReply) ProtoMessage()

func (*SearchReply) ProtoReflect 

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

func (*SearchReply) Reset 

func (x *SearchReply) Reset()

func (*SearchReply) String 

func (x *SearchReply) String() string

type SearchRequest 

type SearchRequest struct {
	Predicate string `protobuf:"bytes,1,opt,name=predicate,proto3" json:"predicate,omitempty"`
	RvID      string `protobuf:"bytes,2,opt,name=rvID,proto3" json:"rvID,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchRequest) Descriptor deprecated 

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetPredicate 

func (x *SearchRequest) GetPredicate() string

func (*SearchRequest) GetRvID 

func (x *SearchRequest) GetRvID() string

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

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

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) String 

func (x *SearchRequest) String() string

type Subscription 

type Subscription struct {
	PeerID    string           `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"`
	Predicate string           `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate,omitempty"`
	RvId      string           `protobuf:"bytes,3,opt,name=rvId,proto3" json:"rvId,omitempty"`
	Shortcut  string           `protobuf:"bytes,4,opt,name=shortcut,proto3" json:"shortcut,omitempty"`
	Backups   map[int32]string `` /* 156-byte string literal not displayed */
	SubAddr   string           `protobuf:"bytes,6,opt,name=subAddr,proto3" json:"subAddr,omitempty"`
	IntAddr   string           `protobuf:"bytes,7,opt,name=intAddr,proto3" json:"intAddr,omitempty"`
	// contains filtered or unexported fields
}

func (*Subscription) Descriptor deprecated 

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

Deprecated: Use Subscription.ProtoReflect.Descriptor instead.

func (*Subscription) GetBackups 

func (x *Subscription) GetBackups() map[int32]string

func (*Subscription) GetIntAddr 

func (x *Subscription) GetIntAddr() string

func (*Subscription) GetPeerID 

func (x *Subscription) GetPeerID() string

func (*Subscription) GetPredicate 

func (x *Subscription) GetPredicate() string

func (*Subscription) GetRvId 

func (x *Subscription) GetRvId() string

func (*Subscription) GetShortcut 

func (x *Subscription) GetShortcut() string

func (*Subscription) GetSubAddr 

func (x *Subscription) GetSubAddr() string

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) ProtoReflect 

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

func (*Subscription) Reset 

func (x *Subscription) Reset()

func (*Subscription) String 

func (x *Subscription) String() string

type UnimplementedScoutHubServer 

type UnimplementedScoutHubServer struct {
}

UnimplementedScoutHubServer must be embedded to have forward compatible implementations.

func (UnimplementedScoutHubServer) AckOp 

func (UnimplementedScoutHubServer) AckOp(context.Context, *Ack) (*Ack, error)

func (UnimplementedScoutHubServer) AckToTracker 

func (UnimplementedScoutHubServer) AckToTracker(context.Context, *EventAck) (*Ack, error)

func (UnimplementedScoutHubServer) AckUp 

func (UnimplementedScoutHubServer) AckUp(context.Context, *EventAck) (*Ack, error)

func (UnimplementedScoutHubServer) AdvertiseGroup 

func (UnimplementedScoutHubServer) AdvertiseGroup(context.Context, *AdvertRequest) (*Ack, error)

func (UnimplementedScoutHubServer) BackupRefresh 

func (UnimplementedScoutHubServer) BackupRefresh(ScoutHub_BackupRefreshServer) error

func (UnimplementedScoutHubServer) DelegateSubToHelper 

func (UnimplementedScoutHubServer) DelegateSubToHelper(context.Context, *DelegateSub) (*Ack, error)

func (UnimplementedScoutHubServer) GroupSearchRequest 

func (UnimplementedScoutHubServer) GroupSearchRequest(context.Context, *SearchRequest) (*SearchReply, error)

func (UnimplementedScoutHubServer) HelpNewRv added in v0.5.20 

func (UnimplementedScoutHubServer) HelpNewRv(context.Context, *Event) (*Ack, error)

func (UnimplementedScoutHubServer) LogToTracker 

func (UnimplementedScoutHubServer) LogToTracker(context.Context, *EventLog) (*Ack, error)

func (UnimplementedScoutHubServer) Notify 

func (UnimplementedScoutHubServer) Notify(context.Context, *Event) (*Ack, error)

func (UnimplementedScoutHubServer) PremiumPublish 

func (UnimplementedScoutHubServer) PremiumPublish(context.Context, *PremiumEvent) (*Ack, error)

func (UnimplementedScoutHubServer) PremiumSubscribe 

func (UnimplementedScoutHubServer) PremiumSubscribe(context.Context, *PremiumSubscription) (*Ack, error)

func (UnimplementedScoutHubServer) PremiumUnsubscribe 

func (UnimplementedScoutHubServer) PremiumUnsubscribe(context.Context, *PremiumSubscription) (*Ack, error)

func (UnimplementedScoutHubServer) Publish 

func (UnimplementedScoutHubServer) Publish(context.Context, *Event) (*Ack, error)

func (UnimplementedScoutHubServer) RequestHelp 

func (UnimplementedScoutHubServer) RequestHelp(context.Context, *HelpRequest) (*Ack, error)

func (UnimplementedScoutHubServer) Subscribe 

func (UnimplementedScoutHubServer) Subscribe(context.Context, *Subscription) (*Ack, error)

func (UnimplementedScoutHubServer) TrackerRefresh 

func (UnimplementedScoutHubServer) TrackerRefresh(context.Context, *RecruitTrackerMessage) (*Ack, error)

func (UnimplementedScoutHubServer) UpdateBackup 

func (UnimplementedScoutHubServer) UpdateBackup(context.Context, *Update) (*Ack, error)

type UnsafeScoutHubServer 

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

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

type Update 

type Update struct {
	Sender    string           `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Route     string           `protobuf:"bytes,2,opt,name=route,proto3" json:"route,omitempty"`
	RouteAddr string           `protobuf:"bytes,3,opt,name=routeAddr,proto3" json:"routeAddr,omitempty"`
	Predicate string           `protobuf:"bytes,4,opt,name=predicate,proto3" json:"predicate,omitempty"`
	Backups   map[int32]string `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Update) Descriptor deprecated 

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

Deprecated: Use Update.ProtoReflect.Descriptor instead.

func (*Update) GetBackups added in v0.13.110 

func (x *Update) GetBackups() map[int32]string

func (*Update) GetPredicate 

func (x *Update) GetPredicate() string

func (*Update) GetRoute 

func (x *Update) GetRoute() string

func (*Update) GetRouteAddr 

func (x *Update) GetRouteAddr() string

func (*Update) GetSender 

func (x *Update) GetSender() string

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) ProtoReflect 

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

func (*Update) Reset 

func (x *Update) Reset()

func (*Update) String 

func (x *Update) String() string

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.