gravity_api_controller

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: 7 Imported by: 0

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

func RegisterControllerServer 

func RegisterControllerServer(s *grpc.Server, srv ControllerServer)

Types

type ControllerClient 

type ControllerClient interface {
	// Core
	GetClientCount(ctx context.Context, in *GetClientCountRequest, opts ...grpc.CallOption) (*GetClientCountReply, error)
	GetPipelineCount(ctx context.Context, in *GetPipelineCountRequest, opts ...grpc.CallOption) (*GetPipelineCountReply, error)
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterReply, error)
	Unregister(ctx context.Context, in *UnregisterRequest, opts ...grpc.CallOption) (*UnregisterReply, error)
	ReleasePipelines(ctx context.Context, in *ReleasePipelinesRequest, opts ...grpc.CallOption) (*ReleasePipelinesReply, error)
	GetPipelines(ctx context.Context, in *GetPipelinesRequest, opts ...grpc.CallOption) (*GetPipelinesReply, error)
	// Adapter
	RegisterAdapter(ctx context.Context, in *RegisterAdapterRequest, opts ...grpc.CallOption) (*RegisterAdapterReply, error)
	UnregisterAdapter(ctx context.Context, in *UnregisterAdapterRequest, opts ...grpc.CallOption) (*UnregisterAdapterReply, error)
	// Subscriber
	RegisterSubscriber(ctx context.Context, in *RegisterSubscriberRequest, opts ...grpc.CallOption) (*RegisterSubscriberReply, error)
	UnregisterSubscriber(ctx context.Context, in *UnregisterSubscriberRequest, opts ...grpc.CallOption) (*UnregisterSubscriberReply, error)
	Resync(ctx context.Context, in *ResyncRequest, opts ...grpc.CallOption) (*ResyncReply, error)
}

ControllerClient is the client API for Controller service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewControllerClient 

func NewControllerClient(cc *grpc.ClientConn) ControllerClient

type ControllerServer 

type ControllerServer interface {
	// Core
	GetClientCount(context.Context, *GetClientCountRequest) (*GetClientCountReply, error)
	GetPipelineCount(context.Context, *GetPipelineCountRequest) (*GetPipelineCountReply, error)
	Register(context.Context, *RegisterRequest) (*RegisterReply, error)
	Unregister(context.Context, *UnregisterRequest) (*UnregisterReply, error)
	ReleasePipelines(context.Context, *ReleasePipelinesRequest) (*ReleasePipelinesReply, error)
	GetPipelines(context.Context, *GetPipelinesRequest) (*GetPipelinesReply, error)
	// Adapter
	RegisterAdapter(context.Context, *RegisterAdapterRequest) (*RegisterAdapterReply, error)
	UnregisterAdapter(context.Context, *UnregisterAdapterRequest) (*UnregisterAdapterReply, error)
	// Subscriber
	RegisterSubscriber(context.Context, *RegisterSubscriberRequest) (*RegisterSubscriberReply, error)
	UnregisterSubscriber(context.Context, *UnregisterSubscriberRequest) (*UnregisterSubscriberReply, error)
	Resync(context.Context, *ResyncRequest) (*ResyncReply, error)
}

ControllerServer is the server API for Controller service.

type GetClientCountReply 

type GetClientCountReply 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"`
	Count                uint64   `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetClientCountReply) Descriptor 

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

func (*GetClientCountReply) GetCount 

func (m *GetClientCountReply) GetCount() uint64

func (*GetClientCountReply) GetReason added in v0.2.12 

func (m *GetClientCountReply) GetReason() string

func (*GetClientCountReply) GetSuccess added in v0.2.12 

func (m *GetClientCountReply) GetSuccess() bool

func (*GetClientCountReply) ProtoMessage 

func (*GetClientCountReply) ProtoMessage()

func (*GetClientCountReply) Reset 

func (m *GetClientCountReply) Reset()

func (*GetClientCountReply) String 

func (m *GetClientCountReply) String() string

func (*GetClientCountReply) XXX_DiscardUnknown 

func (m *GetClientCountReply) XXX_DiscardUnknown()

func (*GetClientCountReply) XXX_Marshal 

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

func (*GetClientCountReply) XXX_Merge 

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

func (*GetClientCountReply) XXX_Size 

func (m *GetClientCountReply) XXX_Size() int

func (*GetClientCountReply) XXX_Unmarshal 

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

type GetClientCountRequest 

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

func (*GetClientCountRequest) Descriptor 

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

func (*GetClientCountRequest) ProtoMessage 

func (*GetClientCountRequest) ProtoMessage()

func (*GetClientCountRequest) Reset 

func (m *GetClientCountRequest) Reset()

func (*GetClientCountRequest) String 

func (m *GetClientCountRequest) String() string

func (*GetClientCountRequest) XXX_DiscardUnknown 

func (m *GetClientCountRequest) XXX_DiscardUnknown()

func (*GetClientCountRequest) XXX_Marshal 

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

func (*GetClientCountRequest) XXX_Merge 

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

func (*GetClientCountRequest) XXX_Size 

func (m *GetClientCountRequest) XXX_Size() int

func (*GetClientCountRequest) XXX_Unmarshal 

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

type GetPipelineCountReply 

type GetPipelineCountReply 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"`
	Count                uint64   `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPipelineCountReply) Descriptor 

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

func (*GetPipelineCountReply) GetCount 

func (m *GetPipelineCountReply) GetCount() uint64

func (*GetPipelineCountReply) GetReason added in v0.2.12 

func (m *GetPipelineCountReply) GetReason() string

func (*GetPipelineCountReply) GetSuccess added in v0.2.12 

func (m *GetPipelineCountReply) GetSuccess() bool

func (*GetPipelineCountReply) ProtoMessage 

func (*GetPipelineCountReply) ProtoMessage()

func (*GetPipelineCountReply) Reset 

func (m *GetPipelineCountReply) Reset()

func (*GetPipelineCountReply) String 

func (m *GetPipelineCountReply) String() string

func (*GetPipelineCountReply) XXX_DiscardUnknown 

func (m *GetPipelineCountReply) XXX_DiscardUnknown()

func (*GetPipelineCountReply) XXX_Marshal 

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

func (*GetPipelineCountReply) XXX_Merge 

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

func (*GetPipelineCountReply) XXX_Size 

func (m *GetPipelineCountReply) XXX_Size() int

func (*GetPipelineCountReply) XXX_Unmarshal 

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

type GetPipelineCountRequest 

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

func (*GetPipelineCountRequest) Descriptor 

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

func (*GetPipelineCountRequest) ProtoMessage 

func (*GetPipelineCountRequest) ProtoMessage()

func (*GetPipelineCountRequest) Reset 

func (m *GetPipelineCountRequest) Reset()

func (*GetPipelineCountRequest) String 

func (m *GetPipelineCountRequest) String() string

func (*GetPipelineCountRequest) XXX_DiscardUnknown 

func (m *GetPipelineCountRequest) XXX_DiscardUnknown()

func (*GetPipelineCountRequest) XXX_Marshal 

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

func (*GetPipelineCountRequest) XXX_Merge 

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

func (*GetPipelineCountRequest) XXX_Size 

func (m *GetPipelineCountRequest) XXX_Size() int

func (*GetPipelineCountRequest) XXX_Unmarshal 

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

type GetPipelinesReply 

type GetPipelinesReply struct {
	Pipelines            []uint64 `protobuf:"varint,1,rep,packed,name=pipelines,proto3" json:"pipelines,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPipelinesReply) Descriptor 

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

func (*GetPipelinesReply) GetPipelines 

func (m *GetPipelinesReply) GetPipelines() []uint64

func (*GetPipelinesReply) ProtoMessage 

func (*GetPipelinesReply) ProtoMessage()

func (*GetPipelinesReply) Reset 

func (m *GetPipelinesReply) Reset()

func (*GetPipelinesReply) String 

func (m *GetPipelinesReply) String() string

func (*GetPipelinesReply) XXX_DiscardUnknown 

func (m *GetPipelinesReply) XXX_DiscardUnknown()

func (*GetPipelinesReply) XXX_Marshal 

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

func (*GetPipelinesReply) XXX_Merge 

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

func (*GetPipelinesReply) XXX_Size 

func (m *GetPipelinesReply) XXX_Size() int

func (*GetPipelinesReply) XXX_Unmarshal 

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

type GetPipelinesRequest 

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

func (*GetPipelinesRequest) Descriptor 

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

func (*GetPipelinesRequest) GetClientID 

func (m *GetPipelinesRequest) GetClientID() string

func (*GetPipelinesRequest) ProtoMessage 

func (*GetPipelinesRequest) ProtoMessage()

func (*GetPipelinesRequest) Reset 

func (m *GetPipelinesRequest) Reset()

func (*GetPipelinesRequest) String 

func (m *GetPipelinesRequest) String() string

func (*GetPipelinesRequest) XXX_DiscardUnknown 

func (m *GetPipelinesRequest) XXX_DiscardUnknown()

func (*GetPipelinesRequest) XXX_Marshal 

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

func (*GetPipelinesRequest) XXX_Merge 

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

func (*GetPipelinesRequest) XXX_Size 

func (m *GetPipelinesRequest) XXX_Size() int

func (*GetPipelinesRequest) XXX_Unmarshal 

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

type Pipeline added in v0.2.12 

type Pipeline struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Sequenece            uint64   `protobuf:"varint,2,opt,name=sequenece,proto3" json:"sequenece,omitempty"`
	Timestamp            uint64   `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Pipeline) Descriptor added in v0.2.12 

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

func (*Pipeline) GetId added in v0.2.12 

func (m *Pipeline) GetId() uint64

func (*Pipeline) GetSequenece added in v0.2.12 

func (m *Pipeline) GetSequenece() uint64

func (*Pipeline) GetTimestamp added in v0.2.12 

func (m *Pipeline) GetTimestamp() uint64

func (*Pipeline) ProtoMessage added in v0.2.12 

func (*Pipeline) ProtoMessage()

func (*Pipeline) Reset added in v0.2.12 

func (m *Pipeline) Reset()

func (*Pipeline) String added in v0.2.12 

func (m *Pipeline) String() string

func (*Pipeline) XXX_DiscardUnknown added in v0.2.12 

func (m *Pipeline) XXX_DiscardUnknown()

func (*Pipeline) XXX_Marshal added in v0.2.12 

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

func (*Pipeline) XXX_Merge added in v0.2.12 

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

func (*Pipeline) XXX_Size added in v0.2.12 

func (m *Pipeline) XXX_Size() int

func (*Pipeline) XXX_Unmarshal added in v0.2.12 

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

type RegisterAdapterReply added in v0.2.6 

type RegisterAdapterReply 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 (*RegisterAdapterReply) Descriptor added in v0.2.6 

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

func (*RegisterAdapterReply) GetReason added in v0.2.6 

func (m *RegisterAdapterReply) GetReason() string

func (*RegisterAdapterReply) GetSuccess added in v0.2.6 

func (m *RegisterAdapterReply) GetSuccess() bool

func (*RegisterAdapterReply) ProtoMessage added in v0.2.6 

func (*RegisterAdapterReply) ProtoMessage()

func (*RegisterAdapterReply) Reset added in v0.2.6 

func (m *RegisterAdapterReply) Reset()

func (*RegisterAdapterReply) String added in v0.2.6 

func (m *RegisterAdapterReply) String() string

func (*RegisterAdapterReply) XXX_DiscardUnknown added in v0.2.6 

func (m *RegisterAdapterReply) XXX_DiscardUnknown()

func (*RegisterAdapterReply) XXX_Marshal added in v0.2.6 

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

func (*RegisterAdapterReply) XXX_Merge added in v0.2.6 

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

func (*RegisterAdapterReply) XXX_Size added in v0.2.6 

func (m *RegisterAdapterReply) XXX_Size() int

func (*RegisterAdapterReply) XXX_Unmarshal added in v0.2.6 

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

type RegisterAdapterRequest added in v0.2.6 

type RegisterAdapterRequest struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
	Url                  string   `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Offset               int64    `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Adapter

func (*RegisterAdapterRequest) Descriptor added in v0.2.6 

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

func (*RegisterAdapterRequest) GetClientID added in v0.2.6 

func (m *RegisterAdapterRequest) GetClientID() string

func (*RegisterAdapterRequest) GetOffset added in v0.2.6 

func (m *RegisterAdapterRequest) GetOffset() int64

func (*RegisterAdapterRequest) GetUrl added in v0.2.6 

func (m *RegisterAdapterRequest) GetUrl() string

func (*RegisterAdapterRequest) ProtoMessage added in v0.2.6 

func (*RegisterAdapterRequest) ProtoMessage()

func (*RegisterAdapterRequest) Reset added in v0.2.6 

func (m *RegisterAdapterRequest) Reset()

func (*RegisterAdapterRequest) String added in v0.2.6 

func (m *RegisterAdapterRequest) String() string

func (*RegisterAdapterRequest) XXX_DiscardUnknown added in v0.2.6 

func (m *RegisterAdapterRequest) XXX_DiscardUnknown()

func (*RegisterAdapterRequest) XXX_Marshal added in v0.2.6 

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

func (*RegisterAdapterRequest) XXX_Merge added in v0.2.6 

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

func (*RegisterAdapterRequest) XXX_Size added in v0.2.6 

func (m *RegisterAdapterRequest) XXX_Size() int

func (*RegisterAdapterRequest) XXX_Unmarshal added in v0.2.6 

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

type RegisterReply 

type RegisterReply 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 (*RegisterReply) Descriptor 

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

func (*RegisterReply) GetReason 

func (m *RegisterReply) GetReason() string

func (*RegisterReply) GetSuccess 

func (m *RegisterReply) GetSuccess() bool

func (*RegisterReply) ProtoMessage 

func (*RegisterReply) ProtoMessage()

func (*RegisterReply) Reset 

func (m *RegisterReply) Reset()

func (*RegisterReply) String 

func (m *RegisterReply) String() string

func (*RegisterReply) XXX_DiscardUnknown 

func (m *RegisterReply) XXX_DiscardUnknown()

func (*RegisterReply) XXX_Marshal 

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

func (*RegisterReply) XXX_Merge 

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

func (*RegisterReply) XXX_Size 

func (m *RegisterReply) XXX_Size() int

func (*RegisterReply) XXX_Unmarshal 

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

type RegisterRequest 

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

func (*RegisterRequest) Descriptor 

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

func (*RegisterRequest) GetClientID 

func (m *RegisterRequest) GetClientID() string

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (m *RegisterRequest) String() string

func (*RegisterRequest) XXX_DiscardUnknown 

func (m *RegisterRequest) XXX_DiscardUnknown()

func (*RegisterRequest) XXX_Marshal 

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

func (*RegisterRequest) XXX_Merge 

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

func (*RegisterRequest) XXX_Size 

func (m *RegisterRequest) XXX_Size() int

func (*RegisterRequest) XXX_Unmarshal 

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

type RegisterSubscriberReply added in v0.2.12 

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 added in v0.2.12 

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

func (*RegisterSubscriberReply) GetReason added in v0.2.12 

func (m *RegisterSubscriberReply) GetReason() string

func (*RegisterSubscriberReply) GetSuccess added in v0.2.12 

func (m *RegisterSubscriberReply) GetSuccess() bool

func (*RegisterSubscriberReply) ProtoMessage added in v0.2.12 

func (*RegisterSubscriberReply) ProtoMessage()

func (*RegisterSubscriberReply) Reset added in v0.2.12 

func (m *RegisterSubscriberReply) Reset()

func (*RegisterSubscriberReply) String added in v0.2.12 

func (m *RegisterSubscriberReply) String() string

func (*RegisterSubscriberReply) XXX_DiscardUnknown added in v0.2.12 

func (m *RegisterSubscriberReply) XXX_DiscardUnknown()

func (*RegisterSubscriberReply) XXX_Marshal added in v0.2.12 

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

func (*RegisterSubscriberReply) XXX_Merge added in v0.2.12 

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

func (*RegisterSubscriberReply) XXX_Size added in v0.2.12 

func (m *RegisterSubscriberReply) XXX_Size() int

func (*RegisterSubscriberReply) XXX_Unmarshal added in v0.2.12 

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

type RegisterSubscriberRequest added in v0.2.12 

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.controller.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 added in v0.2.12 

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

func (*RegisterSubscriberRequest) GetComponent added in v0.2.13 

func (m *RegisterSubscriberRequest) GetComponent() string

func (*RegisterSubscriberRequest) GetName added in v0.2.13 

func (m *RegisterSubscriberRequest) GetName() string

func (*RegisterSubscriberRequest) GetSubscriberID added in v0.2.12 

func (m *RegisterSubscriberRequest) GetSubscriberID() string

func (*RegisterSubscriberRequest) GetType added in v0.2.13 

func (m *RegisterSubscriberRequest) GetType() SubscriberType

func (*RegisterSubscriberRequest) ProtoMessage added in v0.2.12 

func (*RegisterSubscriberRequest) ProtoMessage()

func (*RegisterSubscriberRequest) Reset added in v0.2.12 

func (m *RegisterSubscriberRequest) Reset()

func (*RegisterSubscriberRequest) String added in v0.2.12 

func (m *RegisterSubscriberRequest) String() string

func (*RegisterSubscriberRequest) XXX_DiscardUnknown added in v0.2.12 

func (m *RegisterSubscriberRequest) XXX_DiscardUnknown()

func (*RegisterSubscriberRequest) XXX_Marshal added in v0.2.12 

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

func (*RegisterSubscriberRequest) XXX_Merge added in v0.2.12 

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

func (*RegisterSubscriberRequest) XXX_Size added in v0.2.12 

func (m *RegisterSubscriberRequest) XXX_Size() int

func (*RegisterSubscriberRequest) XXX_Unmarshal added in v0.2.12 

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

type ReleasePipelinesReply 

type ReleasePipelinesReply 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"`
	Failures             []uint64 `protobuf:"varint,3,rep,packed,name=failures,proto3" json:"failures,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReleasePipelinesReply) Descriptor 

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

func (*ReleasePipelinesReply) GetFailures 

func (m *ReleasePipelinesReply) GetFailures() []uint64

func (*ReleasePipelinesReply) GetReason 

func (m *ReleasePipelinesReply) GetReason() string

func (*ReleasePipelinesReply) GetSuccess 

func (m *ReleasePipelinesReply) GetSuccess() bool

func (*ReleasePipelinesReply) ProtoMessage 

func (*ReleasePipelinesReply) ProtoMessage()

func (*ReleasePipelinesReply) Reset 

func (m *ReleasePipelinesReply) Reset()

func (*ReleasePipelinesReply) String 

func (m *ReleasePipelinesReply) String() string

func (*ReleasePipelinesReply) XXX_DiscardUnknown 

func (m *ReleasePipelinesReply) XXX_DiscardUnknown()

func (*ReleasePipelinesReply) XXX_Marshal 

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

func (*ReleasePipelinesReply) XXX_Merge 

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

func (*ReleasePipelinesReply) XXX_Size 

func (m *ReleasePipelinesReply) XXX_Size() int

func (*ReleasePipelinesReply) XXX_Unmarshal 

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

type ReleasePipelinesRequest 

type ReleasePipelinesRequest struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
	Pipelines            []uint64 `protobuf:"varint,2,rep,packed,name=pipelines,proto3" json:"pipelines,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReleasePipelinesRequest) Descriptor 

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

func (*ReleasePipelinesRequest) GetClientID 

func (m *ReleasePipelinesRequest) GetClientID() string

func (*ReleasePipelinesRequest) GetPipelines 

func (m *ReleasePipelinesRequest) GetPipelines() []uint64

func (*ReleasePipelinesRequest) ProtoMessage 

func (*ReleasePipelinesRequest) ProtoMessage()

func (*ReleasePipelinesRequest) Reset 

func (m *ReleasePipelinesRequest) Reset()

func (*ReleasePipelinesRequest) String 

func (m *ReleasePipelinesRequest) String() string

func (*ReleasePipelinesRequest) XXX_DiscardUnknown 

func (m *ReleasePipelinesRequest) XXX_DiscardUnknown()

func (*ReleasePipelinesRequest) XXX_Marshal 

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

func (*ReleasePipelinesRequest) XXX_Merge 

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

func (*ReleasePipelinesRequest) XXX_Size 

func (m *ReleasePipelinesRequest) XXX_Size() int

func (*ReleasePipelinesRequest) XXX_Unmarshal 

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

type ResyncReply added in v0.2.12 

type ResyncReply 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 (*ResyncReply) Descriptor added in v0.2.12 

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

func (*ResyncReply) GetReason added in v0.2.12 

func (m *ResyncReply) GetReason() string

func (*ResyncReply) GetSuccess added in v0.2.12 

func (m *ResyncReply) GetSuccess() bool

func (*ResyncReply) ProtoMessage added in v0.2.12 

func (*ResyncReply) ProtoMessage()

func (*ResyncReply) Reset added in v0.2.12 

func (m *ResyncReply) Reset()

func (*ResyncReply) String added in v0.2.12 

func (m *ResyncReply) String() string

func (*ResyncReply) XXX_DiscardUnknown added in v0.2.12 

func (m *ResyncReply) XXX_DiscardUnknown()

func (*ResyncReply) XXX_Marshal added in v0.2.12 

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

func (*ResyncReply) XXX_Merge added in v0.2.12 

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

func (*ResyncReply) XXX_Size added in v0.2.12 

func (m *ResyncReply) XXX_Size() int

func (*ResyncReply) XXX_Unmarshal added in v0.2.12 

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

type ResyncRequest added in v0.2.12 

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

func (*ResyncRequest) Descriptor added in v0.2.12 

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

func (*ResyncRequest) GetDestinationName added in v0.2.12 

func (m *ResyncRequest) GetDestinationName() string

func (*ResyncRequest) ProtoMessage added in v0.2.12 

func (*ResyncRequest) ProtoMessage()

func (*ResyncRequest) Reset added in v0.2.12 

func (m *ResyncRequest) Reset()

func (*ResyncRequest) String added in v0.2.12 

func (m *ResyncRequest) String() string

func (*ResyncRequest) XXX_DiscardUnknown added in v0.2.12 

func (m *ResyncRequest) XXX_DiscardUnknown()

func (*ResyncRequest) XXX_Marshal added in v0.2.12 

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

func (*ResyncRequest) XXX_Merge added in v0.2.12 

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

func (*ResyncRequest) XXX_Size added in v0.2.12 

func (m *ResyncRequest) XXX_Size() int

func (*ResyncRequest) XXX_Unmarshal added in v0.2.12 

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

type SubscribeToCollectionsReply added in v0.2.12 

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

func (*SubscribeToCollectionsReply) Descriptor added in v0.2.12 

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

func (*SubscribeToCollectionsReply) GetCollections added in v0.2.12 

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

func (*SubscribeToCollectionsReply) GetReason added in v0.2.12 

func (m *SubscribeToCollectionsReply) GetReason() string

func (*SubscribeToCollectionsReply) GetSuccess added in v0.2.12 

func (m *SubscribeToCollectionsReply) GetSuccess() bool

func (*SubscribeToCollectionsReply) ProtoMessage added in v0.2.12 

func (*SubscribeToCollectionsReply) ProtoMessage()

func (*SubscribeToCollectionsReply) Reset added in v0.2.12 

func (m *SubscribeToCollectionsReply) Reset()

func (*SubscribeToCollectionsReply) String added in v0.2.12 

func (m *SubscribeToCollectionsReply) String() string

func (*SubscribeToCollectionsReply) XXX_DiscardUnknown added in v0.2.12 

func (m *SubscribeToCollectionsReply) XXX_DiscardUnknown()

func (*SubscribeToCollectionsReply) XXX_Marshal added in v0.2.12 

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

func (*SubscribeToCollectionsReply) XXX_Merge added in v0.2.12 

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

func (*SubscribeToCollectionsReply) XXX_Size added in v0.2.12 

func (m *SubscribeToCollectionsReply) XXX_Size() int

func (*SubscribeToCollectionsReply) XXX_Unmarshal added in v0.2.12 

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

type SubscribeToCollectionsRequest added in v0.2.12 

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

func (*SubscribeToCollectionsRequest) Descriptor added in v0.2.12 

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

func (*SubscribeToCollectionsRequest) GetCollections added in v0.2.12 

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

func (*SubscribeToCollectionsRequest) GetSubscriberID added in v0.2.12 

func (m *SubscribeToCollectionsRequest) GetSubscriberID() string

func (*SubscribeToCollectionsRequest) ProtoMessage added in v0.2.12 

func (*SubscribeToCollectionsRequest) ProtoMessage()

func (*SubscribeToCollectionsRequest) Reset added in v0.2.12 

func (m *SubscribeToCollectionsRequest) Reset()

func (*SubscribeToCollectionsRequest) String added in v0.2.12 

func (m *SubscribeToCollectionsRequest) String() string

func (*SubscribeToCollectionsRequest) XXX_DiscardUnknown added in v0.2.12 

func (m *SubscribeToCollectionsRequest) XXX_DiscardUnknown()

func (*SubscribeToCollectionsRequest) XXX_Marshal added in v0.2.12 

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

func (*SubscribeToCollectionsRequest) XXX_Merge added in v0.2.12 

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

func (*SubscribeToCollectionsRequest) XXX_Size added in v0.2.12 

func (m *SubscribeToCollectionsRequest) XXX_Size() int

func (*SubscribeToCollectionsRequest) XXX_Unmarshal added in v0.2.12 

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

type SubscriberType added in v0.2.13 

type SubscriberType int32

Subscriber 

const (
	SubscriberType_TRANSMITTER SubscriberType = 0
	SubscriberType_EXPORTER    SubscriberType = 1
)

func (SubscriberType) EnumDescriptor added in v0.2.13 

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

func (SubscriberType) String added in v0.2.13 

func (x SubscriberType) String() string

type UnimplementedControllerServer 

type UnimplementedControllerServer struct {
}

UnimplementedControllerServer can be embedded to have forward compatible implementations.

func (*UnimplementedControllerServer) GetClientCount 

func (*UnimplementedControllerServer) GetClientCount(ctx context.Context, req *GetClientCountRequest) (*GetClientCountReply, error)

func (*UnimplementedControllerServer) GetPipelineCount 

func (*UnimplementedControllerServer) GetPipelineCount(ctx context.Context, req *GetPipelineCountRequest) (*GetPipelineCountReply, error)

func (*UnimplementedControllerServer) GetPipelines 

func (*UnimplementedControllerServer) GetPipelines(ctx context.Context, req *GetPipelinesRequest) (*GetPipelinesReply, error)

func (*UnimplementedControllerServer) Register 

func (*UnimplementedControllerServer) Register(ctx context.Context, req *RegisterRequest) (*RegisterReply, error)

func (*UnimplementedControllerServer) RegisterAdapter added in v0.2.6 

func (*UnimplementedControllerServer) RegisterAdapter(ctx context.Context, req *RegisterAdapterRequest) (*RegisterAdapterReply, error)

func (*UnimplementedControllerServer) RegisterSubscriber added in v0.2.12 

func (*UnimplementedControllerServer) RegisterSubscriber(ctx context.Context, req *RegisterSubscriberRequest) (*RegisterSubscriberReply, error)

func (*UnimplementedControllerServer) ReleasePipelines 

func (*UnimplementedControllerServer) ReleasePipelines(ctx context.Context, req *ReleasePipelinesRequest) (*ReleasePipelinesReply, error)

func (*UnimplementedControllerServer) Resync added in v0.2.12 

func (*UnimplementedControllerServer) Resync(ctx context.Context, req *ResyncRequest) (*ResyncReply, error)

func (*UnimplementedControllerServer) Unregister 

func (*UnimplementedControllerServer) Unregister(ctx context.Context, req *UnregisterRequest) (*UnregisterReply, error)

func (*UnimplementedControllerServer) UnregisterAdapter added in v0.2.6 

func (*UnimplementedControllerServer) UnregisterAdapter(ctx context.Context, req *UnregisterAdapterRequest) (*UnregisterAdapterReply, error)

func (*UnimplementedControllerServer) UnregisterSubscriber added in v0.2.12 

func (*UnimplementedControllerServer) UnregisterSubscriber(ctx context.Context, req *UnregisterSubscriberRequest) (*UnregisterSubscriberReply, error)

type UnregisterAdapterReply added in v0.2.6 

type UnregisterAdapterReply 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 (*UnregisterAdapterReply) Descriptor added in v0.2.6 

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

func (*UnregisterAdapterReply) GetReason added in v0.2.6 

func (m *UnregisterAdapterReply) GetReason() string

func (*UnregisterAdapterReply) GetSuccess added in v0.2.6 

func (m *UnregisterAdapterReply) GetSuccess() bool

func (*UnregisterAdapterReply) ProtoMessage added in v0.2.6 

func (*UnregisterAdapterReply) ProtoMessage()

func (*UnregisterAdapterReply) Reset added in v0.2.6 

func (m *UnregisterAdapterReply) Reset()

func (*UnregisterAdapterReply) String added in v0.2.6 

func (m *UnregisterAdapterReply) String() string

func (*UnregisterAdapterReply) XXX_DiscardUnknown added in v0.2.6 

func (m *UnregisterAdapterReply) XXX_DiscardUnknown()

func (*UnregisterAdapterReply) XXX_Marshal added in v0.2.6 

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

func (*UnregisterAdapterReply) XXX_Merge added in v0.2.6 

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

func (*UnregisterAdapterReply) XXX_Size added in v0.2.6 

func (m *UnregisterAdapterReply) XXX_Size() int

func (*UnregisterAdapterReply) XXX_Unmarshal added in v0.2.6 

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

type UnregisterAdapterRequest added in v0.2.6 

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

func (*UnregisterAdapterRequest) Descriptor added in v0.2.6 

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

func (*UnregisterAdapterRequest) GetClientID added in v0.2.6 

func (m *UnregisterAdapterRequest) GetClientID() string

func (*UnregisterAdapterRequest) ProtoMessage added in v0.2.6 

func (*UnregisterAdapterRequest) ProtoMessage()

func (*UnregisterAdapterRequest) Reset added in v0.2.6 

func (m *UnregisterAdapterRequest) Reset()

func (*UnregisterAdapterRequest) String added in v0.2.6 

func (m *UnregisterAdapterRequest) String() string

func (*UnregisterAdapterRequest) XXX_DiscardUnknown added in v0.2.6 

func (m *UnregisterAdapterRequest) XXX_DiscardUnknown()

func (*UnregisterAdapterRequest) XXX_Marshal added in v0.2.6 

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

func (*UnregisterAdapterRequest) XXX_Merge added in v0.2.6 

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

func (*UnregisterAdapterRequest) XXX_Size added in v0.2.6 

func (m *UnregisterAdapterRequest) XXX_Size() int

func (*UnregisterAdapterRequest) XXX_Unmarshal added in v0.2.6 

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

type UnregisterReply 

type UnregisterReply 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 (*UnregisterReply) Descriptor 

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

func (*UnregisterReply) GetReason 

func (m *UnregisterReply) GetReason() string

func (*UnregisterReply) GetSuccess 

func (m *UnregisterReply) GetSuccess() bool

func (*UnregisterReply) ProtoMessage 

func (*UnregisterReply) ProtoMessage()

func (*UnregisterReply) Reset 

func (m *UnregisterReply) Reset()

func (*UnregisterReply) String 

func (m *UnregisterReply) String() string

func (*UnregisterReply) XXX_DiscardUnknown 

func (m *UnregisterReply) XXX_DiscardUnknown()

func (*UnregisterReply) XXX_Marshal 

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

func (*UnregisterReply) XXX_Merge 

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

func (*UnregisterReply) XXX_Size 

func (m *UnregisterReply) XXX_Size() int

func (*UnregisterReply) XXX_Unmarshal 

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

type UnregisterRequest 

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

func (*UnregisterRequest) Descriptor 

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

func (*UnregisterRequest) GetClientID 

func (m *UnregisterRequest) GetClientID() string

func (*UnregisterRequest) ProtoMessage 

func (*UnregisterRequest) ProtoMessage()

func (*UnregisterRequest) Reset 

func (m *UnregisterRequest) Reset()

func (*UnregisterRequest) String 

func (m *UnregisterRequest) String() string

func (*UnregisterRequest) XXX_DiscardUnknown 

func (m *UnregisterRequest) XXX_DiscardUnknown()

func (*UnregisterRequest) XXX_Marshal 

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

func (*UnregisterRequest) XXX_Merge 

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

func (*UnregisterRequest) XXX_Size 

func (m *UnregisterRequest) XXX_Size() int

func (*UnregisterRequest) XXX_Unmarshal 

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

type UnregisterSubscriberReply added in v0.2.12 

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 added in v0.2.12 

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

func (*UnregisterSubscriberReply) GetReason added in v0.2.12 

func (m *UnregisterSubscriberReply) GetReason() string

func (*UnregisterSubscriberReply) GetSuccess added in v0.2.12 

func (m *UnregisterSubscriberReply) GetSuccess() bool

func (*UnregisterSubscriberReply) ProtoMessage added in v0.2.12 

func (*UnregisterSubscriberReply) ProtoMessage()

func (*UnregisterSubscriberReply) Reset added in v0.2.12 

func (m *UnregisterSubscriberReply) Reset()

func (*UnregisterSubscriberReply) String added in v0.2.12 

func (m *UnregisterSubscriberReply) String() string

func (*UnregisterSubscriberReply) XXX_DiscardUnknown added in v0.2.12 

func (m *UnregisterSubscriberReply) XXX_DiscardUnknown()

func (*UnregisterSubscriberReply) XXX_Marshal added in v0.2.12 

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

func (*UnregisterSubscriberReply) XXX_Merge added in v0.2.12 

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

func (*UnregisterSubscriberReply) XXX_Size added in v0.2.12 

func (m *UnregisterSubscriberReply) XXX_Size() int

func (*UnregisterSubscriberReply) XXX_Unmarshal added in v0.2.12 

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

type UnregisterSubscriberRequest added in v0.2.12 

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 added in v0.2.12 

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

func (*UnregisterSubscriberRequest) GetSubscriberID added in v0.2.12 

func (m *UnregisterSubscriberRequest) GetSubscriberID() string

func (*UnregisterSubscriberRequest) ProtoMessage added in v0.2.12 

func (*UnregisterSubscriberRequest) ProtoMessage()

func (*UnregisterSubscriberRequest) Reset added in v0.2.12 

func (m *UnregisterSubscriberRequest) Reset()

func (*UnregisterSubscriberRequest) String added in v0.2.12 

func (m *UnregisterSubscriberRequest) String() string

func (*UnregisterSubscriberRequest) XXX_DiscardUnknown added in v0.2.12 

func (m *UnregisterSubscriberRequest) XXX_DiscardUnknown()

func (*UnregisterSubscriberRequest) XXX_Marshal added in v0.2.12 

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

func (*UnregisterSubscriberRequest) XXX_Merge added in v0.2.12 

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

func (*UnregisterSubscriberRequest) XXX_Size added in v0.2.12 

func (m *UnregisterSubscriberRequest) XXX_Size() int

func (*UnregisterSubscriberRequest) XXX_Unmarshal added in v0.2.12 

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.