output

Documentation

Index

• func RegisterServiceServer(s *grpc.Server, srv ServiceServer)
• type Request
  • func (*Request) Descriptor() ([]byte, []int)
  • func (m *Request) GetKeepalive() bool
  • func (*Request) ProtoMessage()
  • 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
  • func (*Response) Descriptor() ([]byte, []int)
  • 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 (*Response) ProtoMessage()
  • 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
  • func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient
• type ServiceServer
• type Service_SubscribeClient
• type Service_SubscribeServer
• type UnimplementedServiceServer
  • func (*UnimplementedServiceServer) Subscribe(req *Request, srv Service_SubscribeServer) error

Functions

func RegisterServiceServer

func RegisterServiceServer(s *grpc.Server, srv ServiceServer)

Types

type Request

type Request struct {
	Keepalive            bool     `protobuf:"varint,1,opt,name=keepalive,proto3" json:"keepalive,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The `request` message is the logical representation of the request model. It is the input of the `subscribe` service. It is used to configure the kind of subscription to the gRPC streaming server.

By default the request asks to the server to only receive the accumulated events. In case you want to wait indefinitely for new events to come set the keepalive option to true.

func (*Request) Descriptor

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

func (*Request) GetKeepalive

func (m *Request) GetKeepalive() bool

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) String

func (m *Request) String() string

func (*Request) XXX_DiscardUnknown

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal

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

func (*Request) XXX_Merge

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

func (*Request) XXX_Size

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal

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

type Response

type Response struct {
	Time                 *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Priority             schema.Priority      `protobuf:"varint,2,opt,name=priority,proto3,enum=falco.schema.Priority" json:"priority,omitempty"`
	Source               schema.Source        `protobuf:"varint,3,opt,name=source,proto3,enum=falco.schema.Source" json:"source,omitempty"`
	Rule                 string               `protobuf:"bytes,4,opt,name=rule,proto3" json:"rule,omitempty"`
	Output               string               `protobuf:"bytes,5,opt,name=output,proto3" json:"output,omitempty"`
	OutputFields         map[string]string    `` /* 185-byte string literal not displayed */
	Hostname             string               `protobuf:"bytes,7,opt,name=hostname,proto3" json:"hostname,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

The `response` message is the logical representation of the output model. It contains all the elements that Falco emits in an output along with the definitions for priorities and source.

func (*Response) Descriptor

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

func (*Response) GetHostname

func (m *Response) GetHostname() string

func (*Response) GetOutput

func (m *Response) GetOutput() string

func (*Response) GetOutputFields

func (m *Response) GetOutputFields() map[string]string

func (*Response) GetPriority

func (m *Response) GetPriority() schema.Priority

func (*Response) GetRule

func (m *Response) GetRule() string

func (*Response) GetSource

func (m *Response) GetSource() schema.Source

func (*Response) GetTime

func (m *Response) GetTime() *timestamp.Timestamp

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) String

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal

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

func (*Response) XXX_Merge

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

func (*Response) XXX_Size

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal

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

type ServiceClient

type ServiceClient interface {
	Subscribe(ctx context.Context, in *Request, opts ...grpc.CallOption) (Service_SubscribeClient, error)
}

ServiceClient is the client API for Service service.

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

func NewServiceClient

func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

type ServiceServer

type ServiceServer interface {
	Subscribe(*Request, Service_SubscribeServer) error
}

ServiceServer is the server API for Service service.

type Service_SubscribeClient

type Service_SubscribeClient interface {
	Recv() (*Response, error)
	grpc.ClientStream
}

type Service_SubscribeServer

type Service_SubscribeServer interface {
	Send(*Response) error
	grpc.ServerStream
}

type UnimplementedServiceServer

type UnimplementedServiceServer struct {
}

UnimplementedServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedServiceServer) Subscribe

func (*UnimplementedServiceServer) Subscribe(req *Request, srv Service_SubscribeServer) error