Documentation ¶
Index ¶
- Variables
- func RegisterWatcherServer(s *grpc.Server, srv WatcherServer)
- type Action
- type EventRequest
- func (*EventRequest) Descriptor() ([]byte, []int)
- func (m *EventRequest) GetAction() Action
- func (m *EventRequest) GetContent() []byte
- func (m *EventRequest) GetPath() string
- func (*EventRequest) ProtoMessage()
- func (m *EventRequest) Reset()
- func (m *EventRequest) String() string
- func (m *EventRequest) XXX_DiscardUnknown()
- func (m *EventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventRequest) XXX_Merge(src proto.Message)
- func (m *EventRequest) XXX_Size() int
- func (m *EventRequest) XXX_Unmarshal(b []byte) error
- type WatcherClient
- type WatcherServer
Constants ¶
This section is empty.
Variables ¶
View Source
var Action_name = map[int32]string{
0: "UNKNOWN",
1: "ADDED",
2: "REMOVED",
3: "EDITED",
}
View Source
var Action_value = map[string]int32{
"UNKNOWN": 0,
"ADDED": 1,
"REMOVED": 2,
"EDITED": 3,
}
Functions ¶
func RegisterWatcherServer ¶
func RegisterWatcherServer(s *grpc.Server, srv WatcherServer)
Types ¶
type EventRequest ¶
type EventRequest struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Action Action `protobuf:"varint,2,opt,name=action,proto3,enum=watcher.Action" json:"action,omitempty"` Content []byte `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EventRequest) Descriptor ¶
func (*EventRequest) Descriptor() ([]byte, []int)
func (*EventRequest) GetAction ¶
func (m *EventRequest) GetAction() Action
func (*EventRequest) GetContent ¶
func (m *EventRequest) GetContent() []byte
func (*EventRequest) GetPath ¶
func (m *EventRequest) GetPath() string
func (*EventRequest) ProtoMessage ¶
func (*EventRequest) ProtoMessage()
func (*EventRequest) Reset ¶
func (m *EventRequest) Reset()
func (*EventRequest) String ¶
func (m *EventRequest) String() string
func (*EventRequest) XXX_DiscardUnknown ¶
func (m *EventRequest) XXX_DiscardUnknown()
func (*EventRequest) XXX_Marshal ¶
func (m *EventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventRequest) XXX_Merge ¶
func (m *EventRequest) XXX_Merge(src proto.Message)
func (*EventRequest) XXX_Size ¶
func (m *EventRequest) XXX_Size() int
func (*EventRequest) XXX_Unmarshal ¶
func (m *EventRequest) XXX_Unmarshal(b []byte) error
type WatcherClient ¶
type WatcherClient interface {
Event(ctx context.Context, in *EventRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}
WatcherClient is the client API for Watcher service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewWatcherClient ¶
func NewWatcherClient(cc *grpc.ClientConn) WatcherClient
type WatcherServer ¶
WatcherServer is the server API for Watcher service.
Click to show internal directories.
Click to hide internal directories.