Versions in this module Expand all Collapse all v0 v0.1.0 Apr 20, 2020 Changes in this version + func RegisterServiceServer(s *grpc.Server, srv ServiceServer) + type Request struct + Keepalive bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) GetKeepalive() bool + func (m *Request) Reset() + func (m *Request) String() string + func (m *Request) XXX_DiscardUnknown() + func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Request) XXX_Merge(src proto.Message) + func (m *Request) XXX_Size() int + func (m *Request) XXX_Unmarshal(b []byte) error + type Response struct + Hostname string + Output string + OutputFields map[string]string + Priority schema.Priority + Rule string + Source schema.Source + Time *timestamp.Timestamp + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) GetHostname() string + func (m *Response) GetOutput() string + func (m *Response) GetOutputFields() map[string]string + func (m *Response) GetPriority() schema.Priority + func (m *Response) GetRule() string + func (m *Response) GetSource() schema.Source + func (m *Response) GetTime() *timestamp.Timestamp + func (m *Response) Reset() + func (m *Response) String() string + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Merge(src proto.Message) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + type ServiceClient interface + Subscribe func(ctx context.Context, in *Request, opts ...grpc.CallOption) (Service_SubscribeClient, error) + func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient + type ServiceServer interface + Subscribe func(*Request, Service_SubscribeServer) error + type Service_SubscribeClient interface + Recv func() (*Response, error) + type Service_SubscribeServer interface + Send func(*Response) error + type UnimplementedServiceServer struct + func (*UnimplementedServiceServer) Subscribe(req *Request, srv Service_SubscribeServer) error