client

Documentation

Index

• func NewCrudClientFromConfig(authOptions *shttp.AuthenticationOpts) (*shttp.CrudClient, error)
• func NewRestClientFromConfig(authOptions *shttp.AuthenticationOpts) (*shttp.RestClient, error)
• type GremlinQueryHelper
  • func NewGremlinQueryHelper(authOptions *shttp.AuthenticationOpts) *GremlinQueryHelper
  • func (g *GremlinQueryHelper) GetFlowMetric(query interface{}) (*flow.FlowMetric, error)
  • func (g *GremlinQueryHelper) GetFlowMetrics(query interface{}) (map[string][]*flow.FlowMetric, error)
  • func (g *GremlinQueryHelper) GetFlows(query interface{}) ([]*flow.Flow, error)
  • func (g *GremlinQueryHelper) GetInt64(query interface{}) (int64, error)
  • func (g *GremlinQueryHelper) GetInterfaceMetric(query interface{}) (*topology.InterfaceMetric, error)
  • func (g *GremlinQueryHelper) GetInterfaceMetrics(query interface{}) (map[string][]*topology.InterfaceMetric, error)
  • func (g *GremlinQueryHelper) GetNode(query interface{}) (node *graph.Node, _ error)
  • func (g *GremlinQueryHelper) GetNodes(query interface{}) ([]*graph.Node, error)
  • func (g *GremlinQueryHelper) GetSFlowMetric(query interface{}) (*sflow.SFMetric, error)
  • func (g *GremlinQueryHelper) GetSFlowMetrics(query interface{}) (map[string][]*sflow.SFMetric, error)
  • func (g *GremlinQueryHelper) GetSockets(query interface{}) (sockets map[string][]*socketinfo.ConnectionInfo, err error)
  • func (g *GremlinQueryHelper) Query(query interface{}) ([]byte, error)
  • func (g *GremlinQueryHelper) Request(query interface{}, header http.Header) (*http.Response, error)

Functions

func NewCrudClientFromConfig

func NewCrudClientFromConfig(authOptions *shttp.AuthenticationOpts) (*shttp.CrudClient, error)

NewCrudClientFromConfig creates a new REST client on /api

func NewRestClientFromConfig

func NewRestClientFromConfig(authOptions *shttp.AuthenticationOpts) (*shttp.RestClient, error)

NewRestClientFromConfig creates a new REST client

Types

type GremlinQueryHelper

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

GremlinQueryHelper describes a gremlin query request query helper mechanism

func NewGremlinQueryHelper

func NewGremlinQueryHelper(authOptions *shttp.AuthenticationOpts) *GremlinQueryHelper

NewGremlinQueryHelper creates a new Gremlin query helper based on authentication

func (*GremlinQueryHelper) GetFlowMetric

func (g *GremlinQueryHelper) GetFlowMetric(query interface{}) (*flow.FlowMetric, error)

GetFlowMetric from Gremlin query

func (*GremlinQueryHelper) GetFlowMetrics

func (g *GremlinQueryHelper) GetFlowMetrics(query interface{}) (map[string][]*flow.FlowMetric, error)

GetFlowMetrics from Gremlin query

func (*GremlinQueryHelper) GetFlows

func (g *GremlinQueryHelper) GetFlows(query interface{}) ([]*flow.Flow, error)

GetFlows from the Gremlin query

func (*GremlinQueryHelper) GetInt64

func (g *GremlinQueryHelper) GetInt64(query interface{}) (int64, error)

GetInt64 parse the query result as int64

func (*GremlinQueryHelper) GetInterfaceMetric

func (g *GremlinQueryHelper) GetInterfaceMetric(query interface{}) (*topology.InterfaceMetric, error)

GetInterfaceMetric from Gremlin query

func (*GremlinQueryHelper) GetInterfaceMetrics

func (g *GremlinQueryHelper) GetInterfaceMetrics(query interface{}) (map[string][]*topology.InterfaceMetric, error)

GetInterfaceMetrics from Gremlin query

func (*GremlinQueryHelper) GetNode

func (g *GremlinQueryHelper) GetNode(query interface{}) (node *graph.Node, _ error)

GetNode from the Gremlin query

func (*GremlinQueryHelper) GetNodes

func (g *GremlinQueryHelper) GetNodes(query interface{}) ([]*graph.Node, error)

GetNodes from the Gremlin query

func (*GremlinQueryHelper) GetSFlowMetric

func (g *GremlinQueryHelper) GetSFlowMetric(query interface{}) (*sflow.SFMetric, error)

GetSFlowMetric from Gremlin query

func (*GremlinQueryHelper) GetSFlowMetrics

func (g *GremlinQueryHelper) GetSFlowMetrics(query interface{}) (map[string][]*sflow.SFMetric, error)

GetSFlowMetrics from Gremlin query

func (*GremlinQueryHelper) GetSockets

func (g *GremlinQueryHelper) GetSockets(query interface{}) (sockets map[string][]*socketinfo.ConnectionInfo, err error)

GetSockets from the Gremlin query

func (*GremlinQueryHelper) Query

func (g *GremlinQueryHelper) Query(query interface{}) ([]byte, error)

Query queries the topology API

func (*GremlinQueryHelper) Request

func (g *GremlinQueryHelper) Request(query interface{}, header http.Header) (*http.Response, error)

Request send a Gremlin request to the topology API