analyzers

Documentation

Index

• func NewAnalyzerBiRPCCodec(sc birpc.BirpcCodec, aS *AnalyzerS, enc, from, to string) birpc.BirpcCodec
• func NewAnalyzerServerCodec(sc birpc.ServerCodec, aS *AnalyzerS, enc, from, to string) birpc.ServerCodec
• type AnalyzerBiRPCCodec
  • func (c *AnalyzerBiRPCCodec) Close() error
  • func (c *AnalyzerBiRPCCodec) ReadHeader(req *birpc.Request, resp *birpc.Response) (err error)
  • func (c *AnalyzerBiRPCCodec) ReadRequestBody(x any) (err error)
  • func (c *AnalyzerBiRPCCodec) ReadResponseBody(x any) (err error)
  • func (c *AnalyzerBiRPCCodec) WriteRequest(req *birpc.Request, x any) error
  • func (c *AnalyzerBiRPCCodec) WriteResponse(r *birpc.Response, x any) error
• type AnalyzerConnector
  • func (c *AnalyzerConnector) Call(ctx *context.Context, serviceMethod string, args, reply any) (err error)
• type AnalyzerS
  • func NewAnalyzerS(cfg *config.CGRConfig) (aS *AnalyzerS, err error)
  • func (aS *AnalyzerS) ListenAndServe(ctx *context.Context) (err error)
  • func (aS *AnalyzerS) NewAnalyzerConnector(sc birpc.ClientConnector, enc, from, to string) birpc.ClientConnector
  • func (aS *AnalyzerS) SetFilterS(fS *engine.FilterS)
  • func (aS *AnalyzerS) Shutdown() error
  • func (aS *AnalyzerS) V1StringQuery(ctx *context.Context, args *QueryArgs, reply *[]map[string]any) error
• type AnalyzerServerCodec
  • func (c *AnalyzerServerCodec) Close() error
  • func (c *AnalyzerServerCodec) ReadRequestBody(x any) (err error)
  • func (c *AnalyzerServerCodec) ReadRequestHeader(r *birpc.Request) (err error)
  • func (c *AnalyzerServerCodec) WriteResponse(r *birpc.Response, x any) error
• type InfoRPC
  • func NewInfoRPC(id uint64, method string, params, result, err any, enc, from, to string, ...) *InfoRPC
• type QueryArgs

Functions

func NewAnalyzerBiRPCCodec

func NewAnalyzerBiRPCCodec(sc birpc.BirpcCodec, aS *AnalyzerS, enc, from, to string) birpc.BirpcCodec

func NewAnalyzerServerCodec

func NewAnalyzerServerCodec(sc birpc.ServerCodec, aS *AnalyzerS, enc, from, to string) birpc.ServerCodec

Types

type AnalyzerBiRPCCodec

type AnalyzerBiRPCCodec struct {
	// contains filtered or unexported fields
}

func (*AnalyzerBiRPCCodec) Close

func (c *AnalyzerBiRPCCodec) Close() error

Close is called when client/server finished with the connection.

func (*AnalyzerBiRPCCodec) ReadHeader

func (c *AnalyzerBiRPCCodec) ReadHeader(req *birpc.Request, resp *birpc.Response) (err error)

ReadHeader must read a message and populate either the request or the response by inspecting the incoming message.

func (*AnalyzerBiRPCCodec) ReadRequestBody

func (c *AnalyzerBiRPCCodec) ReadRequestBody(x any) (err error)

ReadRequestBody into args argument of handler function.

func (*AnalyzerBiRPCCodec) ReadResponseBody

func (c *AnalyzerBiRPCCodec) ReadResponseBody(x any) (err error)

ReadResponseBody into reply argument of handler function.

func (*AnalyzerBiRPCCodec) WriteRequest

func (c *AnalyzerBiRPCCodec) WriteRequest(req *birpc.Request, x any) error

WriteRequest must be safe for concurrent use by multiple goroutines.

func (*AnalyzerBiRPCCodec) WriteResponse

func (c *AnalyzerBiRPCCodec) WriteResponse(r *birpc.Response, x any) error

WriteResponse must be safe for concurrent use by multiple goroutines.

type AnalyzerConnector

type AnalyzerConnector struct {
	// contains filtered or unexported fields
}

func (*AnalyzerConnector) Call

func (c *AnalyzerConnector) Call(ctx *context.Context, serviceMethod string, args, reply any) (err error)

type AnalyzerS

type AnalyzerS struct {
	// contains filtered or unexported fields
}

AnalyzerS is the service handling analyzer

func NewAnalyzerS

func NewAnalyzerS(cfg *config.CGRConfig) (aS *AnalyzerS, err error)

NewAnalyzerS initializes a AnalyzerService

func (*AnalyzerS) ListenAndServe

func (aS *AnalyzerS) ListenAndServe(ctx *context.Context) (err error)

ListenAndServe will initialize the service

func (*AnalyzerS) NewAnalyzerConnector

func (aS *AnalyzerS) NewAnalyzerConnector(sc birpc.ClientConnector, enc, from, to string) birpc.ClientConnector

func (*AnalyzerS) SetFilterS

func (aS *AnalyzerS) SetFilterS(fS *engine.FilterS)

SetFilterS will set the filterS used in APIs this function is called before the API is registerd

func (*AnalyzerS) Shutdown

func (aS *AnalyzerS) Shutdown() error

Shutdown is called to shutdown the service

func (*AnalyzerS) V1StringQuery

func (aS *AnalyzerS) V1StringQuery(ctx *context.Context, args *QueryArgs, reply *[]map[string]any) error

V1StringQuery returns a list of API that match the query

type AnalyzerServerCodec

type AnalyzerServerCodec struct {
	// contains filtered or unexported fields
}

func (*AnalyzerServerCodec) Close

func (c *AnalyzerServerCodec) Close() error

func (*AnalyzerServerCodec) ReadRequestBody

func (c *AnalyzerServerCodec) ReadRequestBody(x any) (err error)

func (*AnalyzerServerCodec) ReadRequestHeader

func (c *AnalyzerServerCodec) ReadRequestHeader(r *birpc.Request) (err error)

func (*AnalyzerServerCodec) WriteResponse

func (c *AnalyzerServerCodec) WriteResponse(r *birpc.Response, x any) error

type InfoRPC

type InfoRPC struct {
	RequestDuration  time.Duration
	RequestStartTime time.Time

	RequestEncoding    string
	RequestSource      string
	RequestDestination string

	RequestID     uint64
	RequestMethod string
	RequestParams any
	Reply         any
	ReplyError    any
}

InfoRPC the structure to be indexed

func NewInfoRPC

func NewInfoRPC(id uint64, method string,
	params, result, err any,
	enc, from, to string, sTime, eTime time.Time) *InfoRPC

NewInfoRPC returns a structure to be indexed

type QueryArgs

type QueryArgs struct {
	// a string based on the query language(https://blevesearch.com/docs/Query-String-Query/) that we send to bleve
	HeaderFilters string
	// a list of filters that we use to filter the call similar to how we filter the events
	ContentFilters []string
}

QueryArgs the structure that we use to filter the API calls