gravity_api_controller

May 19, 2021

Changes in this version

+ var SubscriberType_name = map[int32]string

+ var SubscriberType_value = map[string]int32

type RegisterSubscriberRequest

+ Component string

+ Name string

+ Type SubscriberType

+ func (m *RegisterSubscriberRequest) GetComponent() string

+ func (m *RegisterSubscriberRequest) GetName() string

+ func (m *RegisterSubscriberRequest) GetType() SubscriberType

+ type SubscriberType int32

+ const SubscriberType_EXPORTER

+ const SubscriberType_TRANSMITTER

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

+ func (x SubscriberType) String() string

May 17, 2021

Changes in this version

type ControllerClient

+ RegisterSubscriber func(ctx context.Context, in *RegisterSubscriberRequest, opts ...grpc.CallOption) (*RegisterSubscriberReply, error)

+ Resync func(ctx context.Context, in *ResyncRequest, opts ...grpc.CallOption) (*ResyncReply, error)

+ UnregisterSubscriber func(ctx context.Context, in *UnregisterSubscriberRequest, opts ...grpc.CallOption) (*UnregisterSubscriberReply, error)

type ControllerServer

+ RegisterSubscriber func(context.Context, *RegisterSubscriberRequest) (*RegisterSubscriberReply, error)

+ Resync func(context.Context, *ResyncRequest) (*ResyncReply, error)

+ UnregisterSubscriber func(context.Context, *UnregisterSubscriberRequest) (*UnregisterSubscriberReply, error)

type GetClientCountReply

+ Reason string

+ Success bool

+ func (m *GetClientCountReply) GetReason() string

+ func (m *GetClientCountReply) GetSuccess() bool

type GetPipelineCountReply

+ Reason string

+ Success bool

+ func (m *GetPipelineCountReply) GetReason() string

+ func (m *GetPipelineCountReply) GetSuccess() bool

+ type Pipeline struct

+ Id uint64

+ Sequenece uint64

+ Timestamp uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Pipeline) ProtoMessage()

+ func (m *Pipeline) GetId() uint64

+ func (m *Pipeline) GetSequenece() uint64

+ func (m *Pipeline) GetTimestamp() uint64

+ func (m *Pipeline) Reset()

+ func (m *Pipeline) String() string

+ func (m *Pipeline) XXX_DiscardUnknown()

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

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

+ func (m *Pipeline) XXX_Size() int

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

+ type RegisterSubscriberReply struct

+ Channel uint64

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RegisterSubscriberReply) ProtoMessage()

+ func (m *RegisterSubscriberReply) GetChannel() uint64

+ func (m *RegisterSubscriberReply) GetReason() string

+ func (m *RegisterSubscriberReply) GetSuccess() bool

+ func (m *RegisterSubscriberReply) Reset()

+ func (m *RegisterSubscriberReply) String() string

+ func (m *RegisterSubscriberReply) XXX_DiscardUnknown()

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

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

+ func (m *RegisterSubscriberReply) XXX_Size() int

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

+ type RegisterSubscriberRequest struct

+ SubscriberID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RegisterSubscriberRequest) ProtoMessage()

+ func (m *RegisterSubscriberRequest) GetSubscriberID() string

+ func (m *RegisterSubscriberRequest) Reset()

+ func (m *RegisterSubscriberRequest) String() string

+ func (m *RegisterSubscriberRequest) XXX_DiscardUnknown()

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

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

+ func (m *RegisterSubscriberRequest) XXX_Size() int

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

+ type ResyncReply struct

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ResyncReply) ProtoMessage()

+ func (m *ResyncReply) GetReason() string

+ func (m *ResyncReply) GetSuccess() bool

+ func (m *ResyncReply) Reset()

+ func (m *ResyncReply) String() string

+ func (m *ResyncReply) XXX_DiscardUnknown()

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

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

+ func (m *ResyncReply) XXX_Size() int

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

+ type ResyncRequest struct

+ DestinationName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ResyncRequest) ProtoMessage()

+ func (m *ResyncRequest) GetDestinationName() string

+ func (m *ResyncRequest) Reset()

+ func (m *ResyncRequest) String() string

+ func (m *ResyncRequest) XXX_DiscardUnknown()

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

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

+ func (m *ResyncRequest) XXX_Size() int

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

+ type SubscribeToCollectionsReply struct

+ Collections []string

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SubscribeToCollectionsReply) ProtoMessage()

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

+ func (m *SubscribeToCollectionsReply) GetReason() string

+ func (m *SubscribeToCollectionsReply) GetSuccess() bool

+ func (m *SubscribeToCollectionsReply) Reset()

+ func (m *SubscribeToCollectionsReply) String() string

+ func (m *SubscribeToCollectionsReply) XXX_DiscardUnknown()

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

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

+ func (m *SubscribeToCollectionsReply) XXX_Size() int

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

+ type SubscribeToCollectionsRequest struct

+ Collections []string

+ SubscriberID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SubscribeToCollectionsRequest) ProtoMessage()

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

+ func (m *SubscribeToCollectionsRequest) GetSubscriberID() string

+ func (m *SubscribeToCollectionsRequest) Reset()

+ func (m *SubscribeToCollectionsRequest) String() string

+ func (m *SubscribeToCollectionsRequest) XXX_DiscardUnknown()

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

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

+ func (m *SubscribeToCollectionsRequest) XXX_Size() int

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

type UnimplementedControllerServer

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

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

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

+ type UnregisterSubscriberReply struct

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UnregisterSubscriberReply) ProtoMessage()

+ func (m *UnregisterSubscriberReply) GetReason() string

+ func (m *UnregisterSubscriberReply) GetSuccess() bool

+ func (m *UnregisterSubscriberReply) Reset()

+ func (m *UnregisterSubscriberReply) String() string

+ func (m *UnregisterSubscriberReply) XXX_DiscardUnknown()

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

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

+ func (m *UnregisterSubscriberReply) XXX_Size() int

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

+ type UnregisterSubscriberRequest struct

+ SubscriberID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UnregisterSubscriberRequest) ProtoMessage()

+ func (m *UnregisterSubscriberRequest) GetSubscriberID() string

+ func (m *UnregisterSubscriberRequest) Reset()

+ func (m *UnregisterSubscriberRequest) String() string

+ func (m *UnregisterSubscriberRequest) XXX_DiscardUnknown()

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

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

+ func (m *UnregisterSubscriberRequest) XXX_Size() int

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

Dec 21, 2020

Changes in this version

type ControllerClient

+ RegisterAdapter func(ctx context.Context, in *RegisterAdapterRequest, opts ...grpc.CallOption) (*RegisterAdapterReply, error)

+ UnregisterAdapter func(ctx context.Context, in *UnregisterAdapterRequest, opts ...grpc.CallOption) (*UnregisterAdapterReply, error)

type ControllerServer

+ RegisterAdapter func(context.Context, *RegisterAdapterRequest) (*RegisterAdapterReply, error)

+ UnregisterAdapter func(context.Context, *UnregisterAdapterRequest) (*UnregisterAdapterReply, error)

+ type RegisterAdapterReply struct

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RegisterAdapterReply) ProtoMessage()

+ func (m *RegisterAdapterReply) GetReason() string

+ func (m *RegisterAdapterReply) GetSuccess() bool

+ func (m *RegisterAdapterReply) Reset()

+ func (m *RegisterAdapterReply) String() string

+ func (m *RegisterAdapterReply) XXX_DiscardUnknown()

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

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

+ func (m *RegisterAdapterReply) XXX_Size() int

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

+ type RegisterAdapterRequest struct

+ ClientID string

+ Offset int64

+ Url string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RegisterAdapterRequest) ProtoMessage()

+ func (m *RegisterAdapterRequest) GetClientID() string

+ func (m *RegisterAdapterRequest) GetOffset() int64

+ func (m *RegisterAdapterRequest) GetUrl() string

+ func (m *RegisterAdapterRequest) Reset()

+ func (m *RegisterAdapterRequest) String() string

+ func (m *RegisterAdapterRequest) XXX_DiscardUnknown()

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

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

+ func (m *RegisterAdapterRequest) XXX_Size() int

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

type UnimplementedControllerServer

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

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

+ type UnregisterAdapterReply struct

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UnregisterAdapterReply) ProtoMessage()

+ func (m *UnregisterAdapterReply) GetReason() string

+ func (m *UnregisterAdapterReply) GetSuccess() bool

+ func (m *UnregisterAdapterReply) Reset()

+ func (m *UnregisterAdapterReply) String() string

+ func (m *UnregisterAdapterReply) XXX_DiscardUnknown()

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

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

+ func (m *UnregisterAdapterReply) XXX_Size() int

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

+ type UnregisterAdapterRequest struct

+ ClientID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UnregisterAdapterRequest) ProtoMessage()

+ func (m *UnregisterAdapterRequest) GetClientID() string

+ func (m *UnregisterAdapterRequest) Reset()

+ func (m *UnregisterAdapterRequest) String() string

+ func (m *UnregisterAdapterRequest) XXX_DiscardUnknown()

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

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

+ func (m *UnregisterAdapterRequest) XXX_Size() int

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

Oct 11, 2020

Changes in this version

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

+ type ControllerClient interface

+ GetClientCount func(ctx context.Context, in *GetClientCountRequest, opts ...grpc.CallOption) (*GetClientCountReply, error)

+ GetPipelineCount func(ctx context.Context, in *GetPipelineCountRequest, opts ...grpc.CallOption) (*GetPipelineCountReply, error)

+ GetPipelines func(ctx context.Context, in *GetPipelinesRequest, opts ...grpc.CallOption) (*GetPipelinesReply, error)

+ Register func(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterReply, error)

+ ReleasePipelines func(ctx context.Context, in *ReleasePipelinesRequest, opts ...grpc.CallOption) (*ReleasePipelinesReply, error)

+ Unregister func(ctx context.Context, in *UnregisterRequest, opts ...grpc.CallOption) (*UnregisterReply, error)

+ func NewControllerClient(cc *grpc.ClientConn) ControllerClient

+ type ControllerServer interface

+ GetClientCount func(context.Context, *GetClientCountRequest) (*GetClientCountReply, error)

+ GetPipelineCount func(context.Context, *GetPipelineCountRequest) (*GetPipelineCountReply, error)

+ GetPipelines func(context.Context, *GetPipelinesRequest) (*GetPipelinesReply, error)

+ Register func(context.Context, *RegisterRequest) (*RegisterReply, error)

+ ReleasePipelines func(context.Context, *ReleasePipelinesRequest) (*ReleasePipelinesReply, error)

+ Unregister func(context.Context, *UnregisterRequest) (*UnregisterReply, error)

+ type GetClientCountReply struct

+ Count uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetClientCountReply) ProtoMessage()

+ func (m *GetClientCountReply) GetCount() uint64

+ func (m *GetClientCountReply) Reset()

+ func (m *GetClientCountReply) String() string

+ func (m *GetClientCountReply) XXX_DiscardUnknown()

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

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

+ func (m *GetClientCountReply) XXX_Size() int

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

+ type GetClientCountRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetClientCountRequest) ProtoMessage()

+ func (m *GetClientCountRequest) Reset()

+ func (m *GetClientCountRequest) String() string

+ func (m *GetClientCountRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetClientCountRequest) XXX_Size() int

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

+ type GetPipelineCountReply struct

+ Count uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPipelineCountReply) ProtoMessage()

+ func (m *GetPipelineCountReply) GetCount() uint64

+ func (m *GetPipelineCountReply) Reset()

+ func (m *GetPipelineCountReply) String() string

+ func (m *GetPipelineCountReply) XXX_DiscardUnknown()

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

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

+ func (m *GetPipelineCountReply) XXX_Size() int

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

+ type GetPipelineCountRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPipelineCountRequest) ProtoMessage()

+ func (m *GetPipelineCountRequest) Reset()

+ func (m *GetPipelineCountRequest) String() string

+ func (m *GetPipelineCountRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetPipelineCountRequest) XXX_Size() int

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

+ type GetPipelinesReply struct

+ Pipelines []uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPipelinesReply) ProtoMessage()

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

+ func (m *GetPipelinesReply) Reset()

+ func (m *GetPipelinesReply) String() string

+ func (m *GetPipelinesReply) XXX_DiscardUnknown()

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

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

+ func (m *GetPipelinesReply) XXX_Size() int

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

+ type GetPipelinesRequest struct

+ ClientID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPipelinesRequest) ProtoMessage()

+ func (m *GetPipelinesRequest) GetClientID() string

+ func (m *GetPipelinesRequest) Reset()

+ func (m *GetPipelinesRequest) String() string

+ func (m *GetPipelinesRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetPipelinesRequest) XXX_Size() int

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

+ type RegisterReply struct

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RegisterReply) ProtoMessage()

+ func (m *RegisterReply) GetReason() string

+ func (m *RegisterReply) GetSuccess() bool

+ func (m *RegisterReply) Reset()

+ func (m *RegisterReply) String() string

+ func (m *RegisterReply) XXX_DiscardUnknown()

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

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

+ func (m *RegisterReply) XXX_Size() int

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

+ type RegisterRequest struct

+ ClientID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RegisterRequest) ProtoMessage()

+ func (m *RegisterRequest) GetClientID() string

+ func (m *RegisterRequest) Reset()

+ func (m *RegisterRequest) String() string

+ func (m *RegisterRequest) XXX_DiscardUnknown()

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

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

+ func (m *RegisterRequest) XXX_Size() int

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

+ type ReleasePipelinesReply struct

+ Failures []uint64

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReleasePipelinesReply) ProtoMessage()

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

+ func (m *ReleasePipelinesReply) GetReason() string

+ func (m *ReleasePipelinesReply) GetSuccess() bool

+ func (m *ReleasePipelinesReply) Reset()

+ func (m *ReleasePipelinesReply) String() string

+ func (m *ReleasePipelinesReply) XXX_DiscardUnknown()

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

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

+ func (m *ReleasePipelinesReply) XXX_Size() int

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

+ type ReleasePipelinesRequest struct

+ ClientID string

+ Pipelines []uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReleasePipelinesRequest) ProtoMessage()

+ func (m *ReleasePipelinesRequest) GetClientID() string

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

+ func (m *ReleasePipelinesRequest) Reset()

+ func (m *ReleasePipelinesRequest) String() string

+ func (m *ReleasePipelinesRequest) XXX_DiscardUnknown()

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

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

+ func (m *ReleasePipelinesRequest) XXX_Size() int

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

+ type UnimplementedControllerServer struct

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

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

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

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

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

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

+ type UnregisterReply struct

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UnregisterReply) ProtoMessage()

+ func (m *UnregisterReply) GetReason() string

+ func (m *UnregisterReply) GetSuccess() bool

+ func (m *UnregisterReply) Reset()

+ func (m *UnregisterReply) String() string

+ func (m *UnregisterReply) XXX_DiscardUnknown()

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

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

+ func (m *UnregisterReply) XXX_Size() int

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

+ type UnregisterRequest struct

+ ClientID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UnregisterRequest) ProtoMessage()

+ func (m *UnregisterRequest) GetClientID() string

+ func (m *UnregisterRequest) Reset()

+ func (m *UnregisterRequest) String() string

+ func (m *UnregisterRequest) XXX_DiscardUnknown()

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

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

+ func (m *UnregisterRequest) XXX_Size() int

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