Documentation
¶
Index ¶
- func RegisterSynchronizerServer(s *grpc.Server, srv SynchronizerServer)
- type AssignPipelineReply
- func (*AssignPipelineReply) Descriptor() ([]byte, []int)
- func (m *AssignPipelineReply) GetReason() string
- func (m *AssignPipelineReply) GetSuccess() bool
- func (*AssignPipelineReply) ProtoMessage()
- func (m *AssignPipelineReply) Reset()
- func (m *AssignPipelineReply) String() string
- func (m *AssignPipelineReply) XXX_DiscardUnknown()
- func (m *AssignPipelineReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AssignPipelineReply) XXX_Merge(src proto.Message)
- func (m *AssignPipelineReply) XXX_Size() int
- func (m *AssignPipelineReply) XXX_Unmarshal(b []byte) error
- type AssignPipelineRequest
- func (*AssignPipelineRequest) Descriptor() ([]byte, []int)
- func (m *AssignPipelineRequest) GetClientID() string
- func (m *AssignPipelineRequest) GetPipelineID() uint64
- func (*AssignPipelineRequest) ProtoMessage()
- func (m *AssignPipelineRequest) Reset()
- func (m *AssignPipelineRequest) String() string
- func (m *AssignPipelineRequest) XXX_DiscardUnknown()
- func (m *AssignPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AssignPipelineRequest) XXX_Merge(src proto.Message)
- func (m *AssignPipelineRequest) XXX_Size() int
- func (m *AssignPipelineRequest) XXX_Unmarshal(b []byte) error
- type RevokePipelineReply
- func (*RevokePipelineReply) Descriptor() ([]byte, []int)
- func (m *RevokePipelineReply) GetReason() string
- func (m *RevokePipelineReply) GetSuccess() bool
- func (*RevokePipelineReply) ProtoMessage()
- func (m *RevokePipelineReply) Reset()
- func (m *RevokePipelineReply) String() string
- func (m *RevokePipelineReply) XXX_DiscardUnknown()
- func (m *RevokePipelineReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RevokePipelineReply) XXX_Merge(src proto.Message)
- func (m *RevokePipelineReply) XXX_Size() int
- func (m *RevokePipelineReply) XXX_Unmarshal(b []byte) error
- type RevokePipelineRequest
- func (*RevokePipelineRequest) Descriptor() ([]byte, []int)
- func (m *RevokePipelineRequest) GetClientID() string
- func (m *RevokePipelineRequest) GetPipelineID() uint64
- func (*RevokePipelineRequest) ProtoMessage()
- func (m *RevokePipelineRequest) Reset()
- func (m *RevokePipelineRequest) String() string
- func (m *RevokePipelineRequest) XXX_DiscardUnknown()
- func (m *RevokePipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RevokePipelineRequest) XXX_Merge(src proto.Message)
- func (m *RevokePipelineRequest) XXX_Size() int
- func (m *RevokePipelineRequest) XXX_Unmarshal(b []byte) error
- type SynchronizerClient
- type SynchronizerServer
- type UnimplementedSynchronizerServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterSynchronizerServer ¶
func RegisterSynchronizerServer(s *grpc.Server, srv SynchronizerServer)
Types ¶
type AssignPipelineReply ¶
type AssignPipelineReply 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 (*AssignPipelineReply) Descriptor ¶
func (*AssignPipelineReply) Descriptor() ([]byte, []int)
func (*AssignPipelineReply) GetReason ¶
func (m *AssignPipelineReply) GetReason() string
func (*AssignPipelineReply) GetSuccess ¶
func (m *AssignPipelineReply) GetSuccess() bool
func (*AssignPipelineReply) ProtoMessage ¶
func (*AssignPipelineReply) ProtoMessage()
func (*AssignPipelineReply) Reset ¶
func (m *AssignPipelineReply) Reset()
func (*AssignPipelineReply) String ¶
func (m *AssignPipelineReply) String() string
func (*AssignPipelineReply) XXX_DiscardUnknown ¶
func (m *AssignPipelineReply) XXX_DiscardUnknown()
func (*AssignPipelineReply) XXX_Marshal ¶
func (m *AssignPipelineReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AssignPipelineReply) XXX_Merge ¶
func (m *AssignPipelineReply) XXX_Merge(src proto.Message)
func (*AssignPipelineReply) XXX_Size ¶
func (m *AssignPipelineReply) XXX_Size() int
func (*AssignPipelineReply) XXX_Unmarshal ¶
func (m *AssignPipelineReply) XXX_Unmarshal(b []byte) error
type AssignPipelineRequest ¶
type AssignPipelineRequest struct {
ClientID string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
PipelineID uint64 `protobuf:"varint,2,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*AssignPipelineRequest) Descriptor ¶
func (*AssignPipelineRequest) Descriptor() ([]byte, []int)
func (*AssignPipelineRequest) GetClientID ¶
func (m *AssignPipelineRequest) GetClientID() string
func (*AssignPipelineRequest) GetPipelineID ¶
func (m *AssignPipelineRequest) GetPipelineID() uint64
func (*AssignPipelineRequest) ProtoMessage ¶
func (*AssignPipelineRequest) ProtoMessage()
func (*AssignPipelineRequest) Reset ¶
func (m *AssignPipelineRequest) Reset()
func (*AssignPipelineRequest) String ¶
func (m *AssignPipelineRequest) String() string
func (*AssignPipelineRequest) XXX_DiscardUnknown ¶
func (m *AssignPipelineRequest) XXX_DiscardUnknown()
func (*AssignPipelineRequest) XXX_Marshal ¶
func (m *AssignPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AssignPipelineRequest) XXX_Merge ¶
func (m *AssignPipelineRequest) XXX_Merge(src proto.Message)
func (*AssignPipelineRequest) XXX_Size ¶
func (m *AssignPipelineRequest) XXX_Size() int
func (*AssignPipelineRequest) XXX_Unmarshal ¶
func (m *AssignPipelineRequest) XXX_Unmarshal(b []byte) error
type RevokePipelineReply ¶
type RevokePipelineReply 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 (*RevokePipelineReply) Descriptor ¶
func (*RevokePipelineReply) Descriptor() ([]byte, []int)
func (*RevokePipelineReply) GetReason ¶
func (m *RevokePipelineReply) GetReason() string
func (*RevokePipelineReply) GetSuccess ¶
func (m *RevokePipelineReply) GetSuccess() bool
func (*RevokePipelineReply) ProtoMessage ¶
func (*RevokePipelineReply) ProtoMessage()
func (*RevokePipelineReply) Reset ¶
func (m *RevokePipelineReply) Reset()
func (*RevokePipelineReply) String ¶
func (m *RevokePipelineReply) String() string
func (*RevokePipelineReply) XXX_DiscardUnknown ¶
func (m *RevokePipelineReply) XXX_DiscardUnknown()
func (*RevokePipelineReply) XXX_Marshal ¶
func (m *RevokePipelineReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RevokePipelineReply) XXX_Merge ¶
func (m *RevokePipelineReply) XXX_Merge(src proto.Message)
func (*RevokePipelineReply) XXX_Size ¶
func (m *RevokePipelineReply) XXX_Size() int
func (*RevokePipelineReply) XXX_Unmarshal ¶
func (m *RevokePipelineReply) XXX_Unmarshal(b []byte) error
type RevokePipelineRequest ¶
type RevokePipelineRequest struct {
ClientID string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
PipelineID uint64 `protobuf:"varint,2,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*RevokePipelineRequest) Descriptor ¶
func (*RevokePipelineRequest) Descriptor() ([]byte, []int)
func (*RevokePipelineRequest) GetClientID ¶
func (m *RevokePipelineRequest) GetClientID() string
func (*RevokePipelineRequest) GetPipelineID ¶
func (m *RevokePipelineRequest) GetPipelineID() uint64
func (*RevokePipelineRequest) ProtoMessage ¶
func (*RevokePipelineRequest) ProtoMessage()
func (*RevokePipelineRequest) Reset ¶
func (m *RevokePipelineRequest) Reset()
func (*RevokePipelineRequest) String ¶
func (m *RevokePipelineRequest) String() string
func (*RevokePipelineRequest) XXX_DiscardUnknown ¶
func (m *RevokePipelineRequest) XXX_DiscardUnknown()
func (*RevokePipelineRequest) XXX_Marshal ¶
func (m *RevokePipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RevokePipelineRequest) XXX_Merge ¶
func (m *RevokePipelineRequest) XXX_Merge(src proto.Message)
func (*RevokePipelineRequest) XXX_Size ¶
func (m *RevokePipelineRequest) XXX_Size() int
func (*RevokePipelineRequest) XXX_Unmarshal ¶
func (m *RevokePipelineRequest) XXX_Unmarshal(b []byte) error
type SynchronizerClient ¶
type SynchronizerClient interface {
}
SynchronizerClient is the client API for Synchronizer service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewSynchronizerClient ¶
func NewSynchronizerClient(cc *grpc.ClientConn) SynchronizerClient
type SynchronizerServer ¶
type SynchronizerServer interface {
}
SynchronizerServer is the server API for Synchronizer service.
type UnimplementedSynchronizerServer ¶
type UnimplementedSynchronizerServer struct {
}
UnimplementedSynchronizerServer can be embedded to have forward compatible implementations.
Source Files
Click to show internal directories.
Click to hide internal directories.