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{}) (m *flow.FlowMetric, _ error)
  • func (g *GremlinQueryHelper) GetFlows(query interface{}) (flows []*flow.Flow, err error)
  • func (g *GremlinQueryHelper) GetMetric(query interface{}) (common.Metric, error)
  • func (g *GremlinQueryHelper) GetMetrics(query interface{}) (map[string][]common.Metric, error)
  • func (g *GremlinQueryHelper) GetNode(query interface{}) (node *graph.Node, _ error)
  • func (g *GremlinQueryHelper) GetNodes(query interface{}) ([]*graph.Node, error)
  • func (g *GremlinQueryHelper) GetSockets(query interface{}) (sockets map[string][]*socketinfo.ConnectionInfo, err error)
  • func (g *GremlinQueryHelper) QueryObject(query interface{}, value interface{}) error
  • func (g *GremlinQueryHelper) QueryRaw(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{}) (m *flow.FlowMetric, _ error)

GetFlowMetric from Gremlin query

func (*GremlinQueryHelper) GetFlows

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

GetFlows from the Gremlin query

func (*GremlinQueryHelper) GetMetric

func (g *GremlinQueryHelper) GetMetric(query interface{}) (common.Metric, error)

GetMetric from Gremlin query

func (*GremlinQueryHelper) GetMetrics

func (g *GremlinQueryHelper) GetMetrics(query interface{}) (map[string][]common.Metric, error)

GetMetrics 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) GetSockets

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

GetSockets from the Gremlin query

func (*GremlinQueryHelper) QueryObject

func (g *GremlinQueryHelper) QueryObject(query interface{}, value interface{}) error

QueryObject queries the topology API and deserialize into value

func (*GremlinQueryHelper) QueryRaw

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

QueryRaw queries the topology API and returns the raw result

func (*GremlinQueryHelper) Request

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

Request send a Gremlin request to the topology API