gravity_api_subscriber_manager

package
v0.2.13 Latest Latest
Warning

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

 Go to latest Published: May 19, 2021 License: MIT Imports: 3 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

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

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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*GetSubscribersReply) Descriptor 

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

func (*GetSubscribersReply) GetReason 

func (m *GetSubscribersReply) GetReason() string

func (*GetSubscribersReply) GetSubscribers 

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

func (*GetSubscribersReply) GetSuccess 

func (m *GetSubscribersReply) GetSuccess() bool

func (*GetSubscribersReply) ProtoMessage 

func (*GetSubscribersReply) ProtoMessage()

func (*GetSubscribersReply) Reset 

func (m *GetSubscribersReply) Reset()

func (*GetSubscribersReply) String 

func (m *GetSubscribersReply) String() string

func (*GetSubscribersReply) XXX_DiscardUnknown 

func (m *GetSubscribersReply) XXX_DiscardUnknown()

func (*GetSubscribersReply) XXX_Marshal 

func (m *GetSubscribersReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSubscribersReply) XXX_Merge 

func (m *GetSubscribersReply) XXX_Merge(src proto.Message)

func (*GetSubscribersReply) XXX_Size 

func (m *GetSubscribersReply) XXX_Size() int

func (*GetSubscribersReply) XXX_Unmarshal 

func (m *GetSubscribersReply) XXX_Unmarshal(b []byte) error

type GetSubscribersRequest 

type GetSubscribersRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSubscribersRequest) Descriptor 

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

func (*GetSubscribersRequest) ProtoMessage 

func (*GetSubscribersRequest) ProtoMessage()

func (*GetSubscribersRequest) Reset 

func (m *GetSubscribersRequest) Reset()

func (*GetSubscribersRequest) String 

func (m *GetSubscribersRequest) String() string

func (*GetSubscribersRequest) XXX_DiscardUnknown 

func (m *GetSubscribersRequest) XXX_DiscardUnknown()

func (*GetSubscribersRequest) XXX_Marshal 

func (m *GetSubscribersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSubscribersRequest) XXX_Merge 

func (m *GetSubscribersRequest) XXX_Merge(src proto.Message)

func (*GetSubscribersRequest) XXX_Size 

func (m *GetSubscribersRequest) XXX_Size() int

func (*GetSubscribersRequest) XXX_Unmarshal 

func (m *GetSubscribersRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterSubscriberReply) Descriptor 

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

func (*RegisterSubscriberReply) GetReason 

func (m *RegisterSubscriberReply) GetReason() string

func (*RegisterSubscriberReply) GetSuccess 

func (m *RegisterSubscriberReply) GetSuccess() bool

func (*RegisterSubscriberReply) ProtoMessage 

func (*RegisterSubscriberReply) ProtoMessage()

func (*RegisterSubscriberReply) Reset 

func (m *RegisterSubscriberReply) Reset()

func (*RegisterSubscriberReply) String 

func (m *RegisterSubscriberReply) String() string

func (*RegisterSubscriberReply) XXX_DiscardUnknown 

func (m *RegisterSubscriberReply) XXX_DiscardUnknown()

func (*RegisterSubscriberReply) XXX_Marshal 

func (m *RegisterSubscriberReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterSubscriberReply) XXX_Merge 

func (m *RegisterSubscriberReply) XXX_Merge(src proto.Message)

func (*RegisterSubscriberReply) XXX_Size 

func (m *RegisterSubscriberReply) XXX_Size() int

func (*RegisterSubscriberReply) XXX_Unmarshal 

func (m *RegisterSubscriberReply) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*RegisterSubscriberRequest) Descriptor 

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

func (*RegisterSubscriberRequest) GetComponent 

func (m *RegisterSubscriberRequest) GetComponent() string

func (*RegisterSubscriberRequest) GetName 

func (m *RegisterSubscriberRequest) GetName() string

func (*RegisterSubscriberRequest) GetSubscriberID 

func (m *RegisterSubscriberRequest) GetSubscriberID() string

func (*RegisterSubscriberRequest) GetType 

func (m *RegisterSubscriberRequest) GetType() SubscriberType

func (*RegisterSubscriberRequest) ProtoMessage 

func (*RegisterSubscriberRequest) ProtoMessage()

func (*RegisterSubscriberRequest) Reset 

func (m *RegisterSubscriberRequest) Reset()

func (*RegisterSubscriberRequest) String 

func (m *RegisterSubscriberRequest) String() string

func (*RegisterSubscriberRequest) XXX_DiscardUnknown 

func (m *RegisterSubscriberRequest) XXX_DiscardUnknown()

func (*RegisterSubscriberRequest) XXX_Marshal 

func (m *RegisterSubscriberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterSubscriberRequest) XXX_Merge 

func (m *RegisterSubscriberRequest) XXX_Merge(src proto.Message)

func (*RegisterSubscriberRequest) XXX_Size 

func (m *RegisterSubscriberRequest) XXX_Size() int

func (*RegisterSubscriberRequest) XXX_Unmarshal 

func (m *RegisterSubscriberRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Subscriber) Descriptor 

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

func (*Subscriber) GetComponent 

func (m *Subscriber) GetComponent() string

func (*Subscriber) GetName 

func (m *Subscriber) GetName() string

func (*Subscriber) GetSubscriberID 

func (m *Subscriber) GetSubscriberID() string

func (*Subscriber) GetType 

func (m *Subscriber) GetType() SubscriberType

func (*Subscriber) ProtoMessage 

func (*Subscriber) ProtoMessage()

func (*Subscriber) Reset 

func (m *Subscriber) Reset()

func (*Subscriber) String 

func (m *Subscriber) String() string

func (*Subscriber) XXX_DiscardUnknown 

func (m *Subscriber) XXX_DiscardUnknown()

func (*Subscriber) XXX_Marshal 

func (m *Subscriber) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Subscriber) XXX_Merge 

func (m *Subscriber) XXX_Merge(src proto.Message)

func (*Subscriber) XXX_Size 

func (m *Subscriber) XXX_Size() int

func (*Subscriber) XXX_Unmarshal 

func (m *Subscriber) XXX_Unmarshal(b []byte) error

type SubscriberType 

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

func (SubscriberType) EnumDescriptor 

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

func (SubscriberType) String 

func (x SubscriberType) String() string

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnregisterSubscriberReply) Descriptor 

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

func (*UnregisterSubscriberReply) GetReason 

func (m *UnregisterSubscriberReply) GetReason() string

func (*UnregisterSubscriberReply) GetSuccess 

func (m *UnregisterSubscriberReply) GetSuccess() bool

func (*UnregisterSubscriberReply) ProtoMessage 

func (*UnregisterSubscriberReply) ProtoMessage()

func (*UnregisterSubscriberReply) Reset 

func (m *UnregisterSubscriberReply) Reset()

func (*UnregisterSubscriberReply) String 

func (m *UnregisterSubscriberReply) String() string

func (*UnregisterSubscriberReply) XXX_DiscardUnknown 

func (m *UnregisterSubscriberReply) XXX_DiscardUnknown()

func (*UnregisterSubscriberReply) XXX_Marshal 

func (m *UnregisterSubscriberReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnregisterSubscriberReply) XXX_Merge 

func (m *UnregisterSubscriberReply) XXX_Merge(src proto.Message)

func (*UnregisterSubscriberReply) XXX_Size 

func (m *UnregisterSubscriberReply) XXX_Size() int

func (*UnregisterSubscriberReply) XXX_Unmarshal 

func (m *UnregisterSubscriberReply) XXX_Unmarshal(b []byte) error

type UnregisterSubscriberRequest 

type UnregisterSubscriberRequest struct {
	SubscriberID         string   `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnregisterSubscriberRequest) Descriptor 

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

func (*UnregisterSubscriberRequest) GetSubscriberID 

func (m *UnregisterSubscriberRequest) GetSubscriberID() string

func (*UnregisterSubscriberRequest) ProtoMessage 

func (*UnregisterSubscriberRequest) ProtoMessage()

func (*UnregisterSubscriberRequest) Reset 

func (m *UnregisterSubscriberRequest) Reset()

func (*UnregisterSubscriberRequest) String 

func (m *UnregisterSubscriberRequest) String() string

func (*UnregisterSubscriberRequest) XXX_DiscardUnknown 

func (m *UnregisterSubscriberRequest) XXX_DiscardUnknown()

func (*UnregisterSubscriberRequest) XXX_Marshal 

func (m *UnregisterSubscriberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnregisterSubscriberRequest) XXX_Merge 

func (m *UnregisterSubscriberRequest) XXX_Merge(src proto.Message)

func (*UnregisterSubscriberRequest) XXX_Size 

func (m *UnregisterSubscriberRequest) XXX_Size() int

func (*UnregisterSubscriberRequest) XXX_Unmarshal 

func (m *UnregisterSubscriberRequest) XXX_Unmarshal(b []byte) error

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.