Documentation ¶
Index ¶
- Variables
- func RegisterUIServer(s *grpc.Server, srv UIServer)
- type Action
- type ClientConfig
- func (*ClientConfig) Descriptor() ([]byte, []int)
- func (m *ClientConfig) GetConfig() string
- func (m *ClientConfig) GetId() uint64
- func (m *ClientConfig) GetIsFirewallRunning() bool
- func (m *ClientConfig) GetLogLevel() uint32
- func (m *ClientConfig) GetName() string
- func (m *ClientConfig) GetRules() []*Rule
- func (m *ClientConfig) GetVersion() string
- func (*ClientConfig) ProtoMessage()
- func (m *ClientConfig) Reset()
- func (m *ClientConfig) String() string
- type Connection
- func (*Connection) Descriptor() ([]byte, []int)
- func (m *Connection) GetDstHost() string
- func (m *Connection) GetDstIp() string
- func (m *Connection) GetDstPort() uint32
- func (m *Connection) GetProcessArgs() []string
- func (m *Connection) GetProcessCwd() string
- func (m *Connection) GetProcessEnv() map[string]string
- func (m *Connection) GetProcessId() uint32
- func (m *Connection) GetProcessPath() string
- func (m *Connection) GetProtocol() string
- func (m *Connection) GetSrcIp() string
- func (m *Connection) GetSrcPort() uint32
- func (m *Connection) GetUserId() uint32
- func (*Connection) ProtoMessage()
- func (m *Connection) Reset()
- func (m *Connection) String() string
- type Event
- type Notification
- func (*Notification) Descriptor() ([]byte, []int)
- func (m *Notification) GetClientName() string
- func (m *Notification) GetData() string
- func (m *Notification) GetId() uint64
- func (m *Notification) GetRules() []*Rule
- func (m *Notification) GetServerName() string
- func (m *Notification) GetType() Action
- func (*Notification) ProtoMessage()
- func (m *Notification) Reset()
- func (m *Notification) String() string
- type NotificationReply
- func (*NotificationReply) Descriptor() ([]byte, []int)
- func (m *NotificationReply) GetCode() NotificationReplyCode
- func (m *NotificationReply) GetData() string
- func (m *NotificationReply) GetId() uint64
- func (*NotificationReply) ProtoMessage()
- func (m *NotificationReply) Reset()
- func (m *NotificationReply) String() string
- type NotificationReplyCode
- type Operator
- type PingReply
- type PingRequest
- type Rule
- type Statistics
- func (*Statistics) Descriptor() ([]byte, []int)
- func (m *Statistics) GetAccepted() uint64
- func (m *Statistics) GetByAddress() map[string]uint64
- func (m *Statistics) GetByExecutable() map[string]uint64
- func (m *Statistics) GetByHost() map[string]uint64
- func (m *Statistics) GetByPort() map[string]uint64
- func (m *Statistics) GetByProto() map[string]uint64
- func (m *Statistics) GetByUid() map[string]uint64
- func (m *Statistics) GetConnections() uint64
- func (m *Statistics) GetDaemonVersion() string
- func (m *Statistics) GetDnsResponses() uint64
- func (m *Statistics) GetDropped() uint64
- func (m *Statistics) GetEvents() []*Event
- func (m *Statistics) GetIgnored() uint64
- func (m *Statistics) GetRuleHits() uint64
- func (m *Statistics) GetRuleMisses() uint64
- func (m *Statistics) GetRules() uint64
- func (m *Statistics) GetUptime() uint64
- func (*Statistics) ProtoMessage()
- func (m *Statistics) Reset()
- func (m *Statistics) String() string
- type UIClient
- type UIServer
- type UI_NotificationsClient
- type UI_NotificationsServer
- type UnimplementedUIServer
- func (*UnimplementedUIServer) AskRule(ctx context.Context, req *Connection) (*Rule, error)
- func (*UnimplementedUIServer) Notifications(srv UI_NotificationsServer) error
- func (*UnimplementedUIServer) Ping(ctx context.Context, req *PingRequest) (*PingReply, error)
- func (*UnimplementedUIServer) Subscribe(ctx context.Context, req *ClientConfig) (*ClientConfig, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var Action_name = map[int32]string{
0: "NONE",
1: "LOAD_FIREWALL",
2: "UNLOAD_FIREWALL",
3: "CHANGE_CONFIG",
4: "ENABLE_RULE",
5: "DISABLE_RULE",
6: "DELETE_RULE",
7: "CHANGE_RULE",
8: "LOG_LEVEL",
9: "STOP",
}
View Source
var Action_value = map[string]int32{
"NONE": 0,
"LOAD_FIREWALL": 1,
"UNLOAD_FIREWALL": 2,
"CHANGE_CONFIG": 3,
"ENABLE_RULE": 4,
"DISABLE_RULE": 5,
"DELETE_RULE": 6,
"CHANGE_RULE": 7,
"LOG_LEVEL": 8,
"STOP": 9,
}
View Source
var NotificationReplyCode_name = map[int32]string{
0: "OK",
1: "ERROR",
}
View Source
var NotificationReplyCode_value = map[string]int32{
"OK": 0,
"ERROR": 1,
}
Functions ¶
func RegisterUIServer ¶
Types ¶
type Action ¶
type Action int32
const ( Action_NONE Action = 0 Action_LOAD_FIREWALL Action = 1 Action_UNLOAD_FIREWALL Action = 2 Action_CHANGE_CONFIG Action = 3 Action_ENABLE_RULE Action = 4 Action_DISABLE_RULE Action = 5 Action_DELETE_RULE Action = 6 Action_CHANGE_RULE Action = 7 Action_LOG_LEVEL Action = 8 Action_STOP Action = 9 )
func (Action) EnumDescriptor ¶
type ClientConfig ¶
type ClientConfig struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` IsFirewallRunning bool `protobuf:"varint,4,opt,name=isFirewallRunning,proto3" json:"isFirewallRunning,omitempty"` // daemon configuration as json string Config string `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"` LogLevel uint32 `protobuf:"varint,6,opt,name=logLevel,proto3" json:"logLevel,omitempty"` Rules []*Rule `protobuf:"bytes,7,rep,name=rules,proto3" json:"rules,omitempty"` }
client configuration sent on Subscribe()
func (*ClientConfig) Descriptor ¶
func (*ClientConfig) Descriptor() ([]byte, []int)
func (*ClientConfig) GetConfig ¶
func (m *ClientConfig) GetConfig() string
func (*ClientConfig) GetId ¶
func (m *ClientConfig) GetId() uint64
func (*ClientConfig) GetIsFirewallRunning ¶
func (m *ClientConfig) GetIsFirewallRunning() bool
func (*ClientConfig) GetLogLevel ¶
func (m *ClientConfig) GetLogLevel() uint32
func (*ClientConfig) GetName ¶
func (m *ClientConfig) GetName() string
func (*ClientConfig) GetRules ¶
func (m *ClientConfig) GetRules() []*Rule
func (*ClientConfig) GetVersion ¶
func (m *ClientConfig) GetVersion() string
func (*ClientConfig) ProtoMessage ¶
func (*ClientConfig) ProtoMessage()
func (*ClientConfig) Reset ¶
func (m *ClientConfig) Reset()
func (*ClientConfig) String ¶
func (m *ClientConfig) String() string
type Connection ¶
type Connection struct { Protocol string `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"` SrcIp string `protobuf:"bytes,2,opt,name=src_ip,json=srcIp,proto3" json:"src_ip,omitempty"` SrcPort uint32 `protobuf:"varint,3,opt,name=src_port,json=srcPort,proto3" json:"src_port,omitempty"` DstIp string `protobuf:"bytes,4,opt,name=dst_ip,json=dstIp,proto3" json:"dst_ip,omitempty"` DstHost string `protobuf:"bytes,5,opt,name=dst_host,json=dstHost,proto3" json:"dst_host,omitempty"` DstPort uint32 `protobuf:"varint,6,opt,name=dst_port,json=dstPort,proto3" json:"dst_port,omitempty"` UserId uint32 `protobuf:"varint,7,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` ProcessId uint32 `protobuf:"varint,8,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"` ProcessPath string `protobuf:"bytes,9,opt,name=process_path,json=processPath,proto3" json:"process_path,omitempty"` ProcessCwd string `protobuf:"bytes,10,opt,name=process_cwd,json=processCwd,proto3" json:"process_cwd,omitempty"` ProcessArgs []string `protobuf:"bytes,11,rep,name=process_args,json=processArgs,proto3" json:"process_args,omitempty"` ProcessEnv map[string]string `` /* 180-byte string literal not displayed */ }
func (*Connection) Descriptor ¶
func (*Connection) Descriptor() ([]byte, []int)
func (*Connection) GetDstHost ¶
func (m *Connection) GetDstHost() string
func (*Connection) GetDstIp ¶
func (m *Connection) GetDstIp() string
func (*Connection) GetDstPort ¶
func (m *Connection) GetDstPort() uint32
func (*Connection) GetProcessArgs ¶
func (m *Connection) GetProcessArgs() []string
func (*Connection) GetProcessCwd ¶
func (m *Connection) GetProcessCwd() string
func (*Connection) GetProcessEnv ¶
func (m *Connection) GetProcessEnv() map[string]string
func (*Connection) GetProcessId ¶
func (m *Connection) GetProcessId() uint32
func (*Connection) GetProcessPath ¶
func (m *Connection) GetProcessPath() string
func (*Connection) GetProtocol ¶
func (m *Connection) GetProtocol() string
func (*Connection) GetSrcIp ¶
func (m *Connection) GetSrcIp() string
func (*Connection) GetSrcPort ¶
func (m *Connection) GetSrcPort() uint32
func (*Connection) GetUserId ¶
func (m *Connection) GetUserId() uint32
func (*Connection) ProtoMessage ¶
func (*Connection) ProtoMessage()
func (*Connection) Reset ¶
func (m *Connection) Reset()
func (*Connection) String ¶
func (m *Connection) String() string
type Event ¶
type Event struct { Time string `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"` Connection *Connection `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"` Rule *Rule `protobuf:"bytes,3,opt,name=rule,proto3" json:"rule,omitempty"` }
func (*Event) Descriptor ¶
func (*Event) GetConnection ¶
func (m *Event) GetConnection() *Connection
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
type Notification ¶
type Notification struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` ClientName string `protobuf:"bytes,2,opt,name=clientName,proto3" json:"clientName,omitempty"` ServerName string `protobuf:"bytes,3,opt,name=serverName,proto3" json:"serverName,omitempty"` // CHANGE_CONFIG: 2, data: {"default_timeout": 1, ...} Type Action `protobuf:"varint,4,opt,name=type,proto3,enum=protocol.Action" json:"type,omitempty"` Data string `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"` Rules []*Rule `protobuf:"bytes,6,rep,name=rules,proto3" json:"rules,omitempty"` }
notification sent to the clients (daemons)
func (*Notification) Descriptor ¶
func (*Notification) Descriptor() ([]byte, []int)
func (*Notification) GetClientName ¶
func (m *Notification) GetClientName() string
func (*Notification) GetData ¶
func (m *Notification) GetData() string
func (*Notification) GetId ¶
func (m *Notification) GetId() uint64
func (*Notification) GetRules ¶
func (m *Notification) GetRules() []*Rule
func (*Notification) GetServerName ¶
func (m *Notification) GetServerName() string
func (*Notification) GetType ¶
func (m *Notification) GetType() Action
func (*Notification) ProtoMessage ¶
func (*Notification) ProtoMessage()
func (*Notification) Reset ¶
func (m *Notification) Reset()
func (*Notification) String ¶
func (m *Notification) String() string
type NotificationReply ¶
type NotificationReply struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Code NotificationReplyCode `protobuf:"varint,2,opt,name=code,proto3,enum=protocol.NotificationReplyCode" json:"code,omitempty"` Data string `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` }
notification reply sent to the server (GUI)
func (*NotificationReply) Descriptor ¶
func (*NotificationReply) Descriptor() ([]byte, []int)
func (*NotificationReply) GetCode ¶
func (m *NotificationReply) GetCode() NotificationReplyCode
func (*NotificationReply) GetData ¶
func (m *NotificationReply) GetData() string
func (*NotificationReply) GetId ¶
func (m *NotificationReply) GetId() uint64
func (*NotificationReply) ProtoMessage ¶
func (*NotificationReply) ProtoMessage()
func (*NotificationReply) Reset ¶
func (m *NotificationReply) Reset()
func (*NotificationReply) String ¶
func (m *NotificationReply) String() string
type NotificationReplyCode ¶
type NotificationReplyCode int32
const ( NotificationReplyCode_OK NotificationReplyCode = 0 NotificationReplyCode_ERROR NotificationReplyCode = 1 )
func (NotificationReplyCode) EnumDescriptor ¶
func (NotificationReplyCode) EnumDescriptor() ([]byte, []int)
func (NotificationReplyCode) String ¶
func (x NotificationReplyCode) String() string
type Operator ¶
type Operator struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Operand string `protobuf:"bytes,2,opt,name=operand,proto3" json:"operand,omitempty"` Data string `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` }
func (*Operator) Descriptor ¶
func (*Operator) GetOperand ¶
func (*Operator) ProtoMessage ¶
func (*Operator) ProtoMessage()
type PingReply ¶
type PingReply struct {
Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*PingReply) Descriptor ¶
func (*PingReply) ProtoMessage ¶
func (*PingReply) ProtoMessage()
type PingRequest ¶
type PingRequest struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Stats *Statistics `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"` }
func (*PingRequest) Descriptor ¶
func (*PingRequest) Descriptor() ([]byte, []int)
func (*PingRequest) GetId ¶
func (m *PingRequest) GetId() uint64
func (*PingRequest) GetStats ¶
func (m *PingRequest) GetStats() *Statistics
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) Reset ¶
func (m *PingRequest) Reset()
func (*PingRequest) String ¶
func (m *PingRequest) String() string
type Rule ¶
type Rule struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Enabled bool `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"` Action string `protobuf:"bytes,3,opt,name=action,proto3" json:"action,omitempty"` Duration string `protobuf:"bytes,4,opt,name=duration,proto3" json:"duration,omitempty"` Operator *Operator `protobuf:"bytes,5,opt,name=operator,proto3" json:"operator,omitempty"` }
func (*Rule) Descriptor ¶
func (*Rule) GetDuration ¶
func (*Rule) GetEnabled ¶
func (*Rule) GetOperator ¶
func (*Rule) ProtoMessage ¶
func (*Rule) ProtoMessage()
type Statistics ¶
type Statistics struct { DaemonVersion string `protobuf:"bytes,1,opt,name=daemon_version,json=daemonVersion,proto3" json:"daemon_version,omitempty"` Rules uint64 `protobuf:"varint,2,opt,name=rules,proto3" json:"rules,omitempty"` Uptime uint64 `protobuf:"varint,3,opt,name=uptime,proto3" json:"uptime,omitempty"` DnsResponses uint64 `protobuf:"varint,4,opt,name=dns_responses,json=dnsResponses,proto3" json:"dns_responses,omitempty"` Connections uint64 `protobuf:"varint,5,opt,name=connections,proto3" json:"connections,omitempty"` Ignored uint64 `protobuf:"varint,6,opt,name=ignored,proto3" json:"ignored,omitempty"` Accepted uint64 `protobuf:"varint,7,opt,name=accepted,proto3" json:"accepted,omitempty"` Dropped uint64 `protobuf:"varint,8,opt,name=dropped,proto3" json:"dropped,omitempty"` RuleHits uint64 `protobuf:"varint,9,opt,name=rule_hits,json=ruleHits,proto3" json:"rule_hits,omitempty"` RuleMisses uint64 `protobuf:"varint,10,opt,name=rule_misses,json=ruleMisses,proto3" json:"rule_misses,omitempty"` ByProto map[string]uint64 `` /* 172-byte string literal not displayed */ ByAddress map[string]uint64 `` /* 178-byte string literal not displayed */ ByHost map[string]uint64 `` /* 169-byte string literal not displayed */ ByPort map[string]uint64 `` /* 169-byte string literal not displayed */ ByUid map[string]uint64 `` /* 166-byte string literal not displayed */ ByExecutable map[string]uint64 `` /* 187-byte string literal not displayed */ Events []*Event `protobuf:"bytes,17,rep,name=events,proto3" json:"events,omitempty"` }
func (*Statistics) Descriptor ¶
func (*Statistics) Descriptor() ([]byte, []int)
func (*Statistics) GetAccepted ¶
func (m *Statistics) GetAccepted() uint64
func (*Statistics) GetByAddress ¶
func (m *Statistics) GetByAddress() map[string]uint64
func (*Statistics) GetByExecutable ¶
func (m *Statistics) GetByExecutable() map[string]uint64
func (*Statistics) GetByHost ¶
func (m *Statistics) GetByHost() map[string]uint64
func (*Statistics) GetByPort ¶
func (m *Statistics) GetByPort() map[string]uint64
func (*Statistics) GetByProto ¶
func (m *Statistics) GetByProto() map[string]uint64
func (*Statistics) GetByUid ¶
func (m *Statistics) GetByUid() map[string]uint64
func (*Statistics) GetConnections ¶
func (m *Statistics) GetConnections() uint64
func (*Statistics) GetDaemonVersion ¶
func (m *Statistics) GetDaemonVersion() string
func (*Statistics) GetDnsResponses ¶
func (m *Statistics) GetDnsResponses() uint64
func (*Statistics) GetDropped ¶
func (m *Statistics) GetDropped() uint64
func (*Statistics) GetEvents ¶
func (m *Statistics) GetEvents() []*Event
func (*Statistics) GetIgnored ¶
func (m *Statistics) GetIgnored() uint64
func (*Statistics) GetRuleHits ¶
func (m *Statistics) GetRuleHits() uint64
func (*Statistics) GetRuleMisses ¶
func (m *Statistics) GetRuleMisses() uint64
func (*Statistics) GetRules ¶
func (m *Statistics) GetRules() uint64
func (*Statistics) GetUptime ¶
func (m *Statistics) GetUptime() uint64
func (*Statistics) ProtoMessage ¶
func (*Statistics) ProtoMessage()
func (*Statistics) Reset ¶
func (m *Statistics) Reset()
func (*Statistics) String ¶
func (m *Statistics) String() string
type UIClient ¶
type UIClient interface { Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingReply, error) AskRule(ctx context.Context, in *Connection, opts ...grpc.CallOption) (*Rule, error) Subscribe(ctx context.Context, in *ClientConfig, opts ...grpc.CallOption) (*ClientConfig, error) Notifications(ctx context.Context, opts ...grpc.CallOption) (UI_NotificationsClient, error) }
UIClient is the client API for UI service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewUIClient ¶
func NewUIClient(cc *grpc.ClientConn) UIClient
type UIServer ¶
type UIServer interface { Ping(context.Context, *PingRequest) (*PingReply, error) AskRule(context.Context, *Connection) (*Rule, error) Subscribe(context.Context, *ClientConfig) (*ClientConfig, error) Notifications(UI_NotificationsServer) error }
UIServer is the server API for UI service.
type UI_NotificationsClient ¶
type UI_NotificationsClient interface { Send(*NotificationReply) error Recv() (*Notification, error) grpc.ClientStream }
type UI_NotificationsServer ¶
type UI_NotificationsServer interface { Send(*Notification) error Recv() (*NotificationReply, error) grpc.ServerStream }
type UnimplementedUIServer ¶
type UnimplementedUIServer struct { }
UnimplementedUIServer can be embedded to have forward compatible implementations.
func (*UnimplementedUIServer) AskRule ¶
func (*UnimplementedUIServer) AskRule(ctx context.Context, req *Connection) (*Rule, error)
func (*UnimplementedUIServer) Notifications ¶
func (*UnimplementedUIServer) Notifications(srv UI_NotificationsServer) error
func (*UnimplementedUIServer) Ping ¶
func (*UnimplementedUIServer) Ping(ctx context.Context, req *PingRequest) (*PingReply, error)
func (*UnimplementedUIServer) Subscribe ¶
func (*UnimplementedUIServer) Subscribe(ctx context.Context, req *ClientConfig) (*ClientConfig, error)
Click to show internal directories.
Click to hide internal directories.