__

package
v0.2.28 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2022 License: MIT Imports: 5 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SubscriberType_name = map[int32]string{
		0: "TRANSMITTER",
		1: "EXPORTER",
	}
	SubscriberType_value = map[string]int32{
		"TRANSMITTER": 0,
		"EXPORTER":    1,
	}
)

Enum value maps for SubscriberType.

View Source 
var File_subscriber_manager_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type GetSubscribersReply 

type GetSubscribersReply struct {
	Success     bool          `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason      string        `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Subscribers []*Subscriber `protobuf:"bytes,3,rep,name=subscribers,proto3" json:"subscribers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSubscribersReply) Descriptor deprecated 

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

Deprecated: Use GetSubscribersReply.ProtoReflect.Descriptor instead.

func (*GetSubscribersReply) GetReason 

func (x *GetSubscribersReply) GetReason() string

func (*GetSubscribersReply) GetSubscribers 

func (x *GetSubscribersReply) GetSubscribers() []*Subscriber

func (*GetSubscribersReply) GetSuccess 

func (x *GetSubscribersReply) GetSuccess() bool

func (*GetSubscribersReply) ProtoMessage 

func (*GetSubscribersReply) ProtoMessage()

func (*GetSubscribersReply) ProtoReflect added in v0.0.22 

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

func (*GetSubscribersReply) Reset 

func (x *GetSubscribersReply) Reset()

func (*GetSubscribersReply) String 

func (x *GetSubscribersReply) String() string

type GetSubscribersRequest 

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

func (*GetSubscribersRequest) Descriptor deprecated 

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

Deprecated: Use GetSubscribersRequest.ProtoReflect.Descriptor instead.

func (*GetSubscribersRequest) ProtoMessage 

func (*GetSubscribersRequest) ProtoMessage()

func (*GetSubscribersRequest) ProtoReflect added in v0.0.22 

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

func (*GetSubscribersRequest) Reset 

func (x *GetSubscribersRequest) Reset()

func (*GetSubscribersRequest) String 

func (x *GetSubscribersRequest) String() string

type HealthCheckReply 

type HealthCheckReply struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason  string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckReply) Descriptor deprecated 

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

Deprecated: Use HealthCheckReply.ProtoReflect.Descriptor instead.

func (*HealthCheckReply) GetReason 

func (x *HealthCheckReply) GetReason() string

func (*HealthCheckReply) GetSuccess 

func (x *HealthCheckReply) GetSuccess() bool

func (*HealthCheckReply) ProtoMessage 

func (*HealthCheckReply) ProtoMessage()

func (*HealthCheckReply) ProtoReflect added in v0.0.22 

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

func (*HealthCheckReply) Reset 

func (x *HealthCheckReply) Reset()

func (*HealthCheckReply) String 

func (x *HealthCheckReply) String() string

type HealthCheckRequest 

type HealthCheckRequest struct {
	SubscriberID string `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) GetSubscriberID 

func (x *HealthCheckRequest) GetSubscriberID() string

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect added in v0.0.22 

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

func (*HealthCheckRequest) Reset 

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (x *HealthCheckRequest) String() string

type RegisterSubscriberReply 

type RegisterSubscriberReply struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason  string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Token   string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterSubscriberReply) Descriptor deprecated 

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

Deprecated: Use RegisterSubscriberReply.ProtoReflect.Descriptor instead.

func (*RegisterSubscriberReply) GetReason 

func (x *RegisterSubscriberReply) GetReason() string

func (*RegisterSubscriberReply) GetSuccess 

func (x *RegisterSubscriberReply) GetSuccess() bool

func (*RegisterSubscriberReply) GetToken added in v0.2.24 

func (x *RegisterSubscriberReply) GetToken() string

func (*RegisterSubscriberReply) ProtoMessage 

func (*RegisterSubscriberReply) ProtoMessage()

func (*RegisterSubscriberReply) ProtoReflect added in v0.0.22 

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

func (*RegisterSubscriberReply) Reset 

func (x *RegisterSubscriberReply) Reset()

func (*RegisterSubscriberReply) String 

func (x *RegisterSubscriberReply) String() string

type RegisterSubscriberRequest 

type RegisterSubscriberRequest struct {
	SubscriberID string         `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"`
	Name         string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type         SubscriberType `protobuf:"varint,3,opt,name=type,proto3,enum=gravity.api.subscriber_manager.SubscriberType" json:"type,omitempty"`
	Component    string         `protobuf:"bytes,4,opt,name=component,proto3" json:"component,omitempty"`
	AppID        string         `protobuf:"bytes,5,opt,name=appID,proto3" json:"appID,omitempty"`
	Token        []byte         `protobuf:"bytes,6,opt,name=token,proto3" json:"token,omitempty"`
	Pipelines    []uint64       `protobuf:"varint,7,rep,packed,name=pipelines,proto3" json:"pipelines,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterSubscriberRequest) Descriptor deprecated 

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

Deprecated: Use RegisterSubscriberRequest.ProtoReflect.Descriptor instead.

func (*RegisterSubscriberRequest) GetAppID added in v0.0.22 

func (x *RegisterSubscriberRequest) GetAppID() string

func (*RegisterSubscriberRequest) GetComponent 

func (x *RegisterSubscriberRequest) GetComponent() string

func (*RegisterSubscriberRequest) GetName 

func (x *RegisterSubscriberRequest) GetName() string

func (*RegisterSubscriberRequest) GetPipelines added in v0.2.26 

func (x *RegisterSubscriberRequest) GetPipelines() []uint64

func (*RegisterSubscriberRequest) GetSubscriberID 

func (x *RegisterSubscriberRequest) GetSubscriberID() string

func (*RegisterSubscriberRequest) GetToken added in v0.0.22 

func (x *RegisterSubscriberRequest) GetToken() []byte

func (*RegisterSubscriberRequest) GetType 

func (x *RegisterSubscriberRequest) GetType() SubscriberType

func (*RegisterSubscriberRequest) ProtoMessage 

func (*RegisterSubscriberRequest) ProtoMessage()

func (*RegisterSubscriberRequest) ProtoReflect added in v0.0.22 

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

func (*RegisterSubscriberRequest) Reset 

func (x *RegisterSubscriberRequest) Reset()

func (*RegisterSubscriberRequest) String 

func (x *RegisterSubscriberRequest) String() string

type SubscribeToCollectionsReply 

type SubscribeToCollectionsReply struct {
	Success     bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason      string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Collections []string `protobuf:"bytes,3,rep,name=collections,proto3" json:"collections,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeToCollectionsReply) Descriptor deprecated 

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

Deprecated: Use SubscribeToCollectionsReply.ProtoReflect.Descriptor instead.

func (*SubscribeToCollectionsReply) GetCollections 

func (x *SubscribeToCollectionsReply) GetCollections() []string

func (*SubscribeToCollectionsReply) GetReason 

func (x *SubscribeToCollectionsReply) GetReason() string

func (*SubscribeToCollectionsReply) GetSuccess 

func (x *SubscribeToCollectionsReply) GetSuccess() bool

func (*SubscribeToCollectionsReply) ProtoMessage 

func (*SubscribeToCollectionsReply) ProtoMessage()

func (*SubscribeToCollectionsReply) ProtoReflect added in v0.0.22 

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

func (*SubscribeToCollectionsReply) Reset 

func (x *SubscribeToCollectionsReply) Reset()

func (*SubscribeToCollectionsReply) String 

func (x *SubscribeToCollectionsReply) String() string

type SubscribeToCollectionsRequest 

type SubscribeToCollectionsRequest struct {
	SubscriberID string   `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"`
	Collections  []string `protobuf:"bytes,2,rep,name=collections,proto3" json:"collections,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeToCollectionsRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeToCollectionsRequest.ProtoReflect.Descriptor instead.

func (*SubscribeToCollectionsRequest) GetCollections 

func (x *SubscribeToCollectionsRequest) GetCollections() []string

func (*SubscribeToCollectionsRequest) GetSubscriberID 

func (x *SubscribeToCollectionsRequest) GetSubscriberID() string

func (*SubscribeToCollectionsRequest) ProtoMessage 

func (*SubscribeToCollectionsRequest) ProtoMessage()

func (*SubscribeToCollectionsRequest) ProtoReflect added in v0.0.22 

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

func (*SubscribeToCollectionsRequest) Reset 

func (x *SubscribeToCollectionsRequest) Reset()

func (*SubscribeToCollectionsRequest) String 

func (x *SubscribeToCollectionsRequest) String() string

type Subscriber 

type Subscriber struct {
	SubscriberID string                 `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"`
	Name         string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type         SubscriberType         `protobuf:"varint,3,opt,name=type,proto3,enum=gravity.api.subscriber_manager.SubscriberType" json:"type,omitempty"`
	Component    string                 `protobuf:"bytes,4,opt,name=component,proto3" json:"component,omitempty"`
	LastCheck    *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=lastCheck,proto3" json:"lastCheck,omitempty"`
	AppID        string                 `protobuf:"bytes,6,opt,name=appID,proto3" json:"appID,omitempty"`
	AccessKey    string                 `protobuf:"bytes,7,opt,name=accessKey,proto3" json:"accessKey,omitempty"`
	Permissions  []string               `protobuf:"bytes,8,rep,name=permissions,proto3" json:"permissions,omitempty"`
	Collections  []string               `protobuf:"bytes,9,rep,name=collections,proto3" json:"collections,omitempty"`
	Pipelines    []uint64               `protobuf:"varint,10,rep,packed,name=pipelines,proto3" json:"pipelines,omitempty"`
	// contains filtered or unexported fields
}

func (*Subscriber) Descriptor deprecated 

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

Deprecated: Use Subscriber.ProtoReflect.Descriptor instead.

func (*Subscriber) GetAccessKey added in v0.0.22 

func (x *Subscriber) GetAccessKey() string

func (*Subscriber) GetAppID added in v0.0.22 

func (x *Subscriber) GetAppID() string

func (*Subscriber) GetCollections added in v0.2.24 

func (x *Subscriber) GetCollections() []string

func (*Subscriber) GetComponent 

func (x *Subscriber) GetComponent() string

func (*Subscriber) GetLastCheck 

func (x *Subscriber) GetLastCheck() *timestamppb.Timestamp

func (*Subscriber) GetName 

func (x *Subscriber) GetName() string

func (*Subscriber) GetPermissions added in v0.0.22 

func (x *Subscriber) GetPermissions() []string

func (*Subscriber) GetPipelines added in v0.2.26 

func (x *Subscriber) GetPipelines() []uint64

func (*Subscriber) GetSubscriberID 

func (x *Subscriber) GetSubscriberID() string

func (*Subscriber) GetType 

func (x *Subscriber) GetType() SubscriberType

func (*Subscriber) ProtoMessage 

func (*Subscriber) ProtoMessage()

func (*Subscriber) ProtoReflect added in v0.0.22 

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

func (*Subscriber) Reset 

func (x *Subscriber) Reset()

func (*Subscriber) String 

func (x *Subscriber) String() string

type SubscriberType 

type SubscriberType int32
const (
	SubscriberType_TRANSMITTER SubscriberType = 0
	SubscriberType_EXPORTER    SubscriberType = 1
)

func (SubscriberType) Descriptor added in v0.0.22 

func (SubscriberType) Descriptor() protoreflect.EnumDescriptor

func (SubscriberType) Enum added in v0.0.22 

func (x SubscriberType) Enum() *SubscriberType

func (SubscriberType) EnumDescriptor deprecated 

func (SubscriberType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SubscriberType.Descriptor instead.

func (SubscriberType) Number added in v0.0.22 

func (x SubscriberType) Number() protoreflect.EnumNumber

func (SubscriberType) String 

func (x SubscriberType) String() string

func (SubscriberType) Type added in v0.0.22 

func (SubscriberType) Type() protoreflect.EnumType

type UnregisterSubscriberReply 

type UnregisterSubscriberReply struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason  string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*UnregisterSubscriberReply) Descriptor deprecated 

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

Deprecated: Use UnregisterSubscriberReply.ProtoReflect.Descriptor instead.

func (*UnregisterSubscriberReply) GetReason 

func (x *UnregisterSubscriberReply) GetReason() string

func (*UnregisterSubscriberReply) GetSuccess 

func (x *UnregisterSubscriberReply) GetSuccess() bool

func (*UnregisterSubscriberReply) ProtoMessage 

func (*UnregisterSubscriberReply) ProtoMessage()

func (*UnregisterSubscriberReply) ProtoReflect added in v0.0.22 

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

func (*UnregisterSubscriberReply) Reset 

func (x *UnregisterSubscriberReply) Reset()

func (*UnregisterSubscriberReply) String 

func (x *UnregisterSubscriberReply) String() string

type UnregisterSubscriberRequest 

type UnregisterSubscriberRequest struct {
	SubscriberID string `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"`
	// contains filtered or unexported fields
}

func (*UnregisterSubscriberRequest) Descriptor deprecated 

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

Deprecated: Use UnregisterSubscriberRequest.ProtoReflect.Descriptor instead.

func (*UnregisterSubscriberRequest) GetSubscriberID 

func (x *UnregisterSubscriberRequest) GetSubscriberID() string

func (*UnregisterSubscriberRequest) ProtoMessage 

func (*UnregisterSubscriberRequest) ProtoMessage()

func (*UnregisterSubscriberRequest) ProtoReflect added in v0.0.22 

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

func (*UnregisterSubscriberRequest) Reset 

func (x *UnregisterSubscriberRequest) Reset()

func (*UnregisterSubscriberRequest) String 

func (x *UnregisterSubscriberRequest) String() string

type UpdateSubscriberPropsReply added in v0.2.26 

type UpdateSubscriberPropsReply struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason  string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSubscriberPropsReply) Descriptor deprecated added in v0.2.26 

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

Deprecated: Use UpdateSubscriberPropsReply.ProtoReflect.Descriptor instead.

func (*UpdateSubscriberPropsReply) GetReason added in v0.2.26 

func (x *UpdateSubscriberPropsReply) GetReason() string

func (*UpdateSubscriberPropsReply) GetSuccess added in v0.2.26 

func (x *UpdateSubscriberPropsReply) GetSuccess() bool

func (*UpdateSubscriberPropsReply) ProtoMessage added in v0.2.26 

func (*UpdateSubscriberPropsReply) ProtoMessage()

func (*UpdateSubscriberPropsReply) ProtoReflect added in v0.2.26 

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

func (*UpdateSubscriberPropsReply) Reset added in v0.2.26 

func (x *UpdateSubscriberPropsReply) Reset()

func (*UpdateSubscriberPropsReply) String added in v0.2.26 

func (x *UpdateSubscriberPropsReply) String() string

type UpdateSubscriberPropsRequest added in v0.2.26 

type UpdateSubscriberPropsRequest struct {
	SubscriberID string   `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"`
	Pipelines    []uint64 `protobuf:"varint,2,rep,packed,name=pipelines,proto3" json:"pipelines,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSubscriberPropsRequest) Descriptor deprecated added in v0.2.26 

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

Deprecated: Use UpdateSubscriberPropsRequest.ProtoReflect.Descriptor instead.

func (*UpdateSubscriberPropsRequest) GetPipelines added in v0.2.26 

func (x *UpdateSubscriberPropsRequest) GetPipelines() []uint64

func (*UpdateSubscriberPropsRequest) GetSubscriberID added in v0.2.26 

func (x *UpdateSubscriberPropsRequest) GetSubscriberID() string

func (*UpdateSubscriberPropsRequest) ProtoMessage added in v0.2.26 

func (*UpdateSubscriberPropsRequest) ProtoMessage()

func (*UpdateSubscriberPropsRequest) ProtoReflect added in v0.2.26 

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

func (*UpdateSubscriberPropsRequest) Reset added in v0.2.26 

func (x *UpdateSubscriberPropsRequest) Reset()

func (*UpdateSubscriberPropsRequest) String added in v0.2.26 

func (x *UpdateSubscriberPropsRequest) 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.