monitor

package
v2.5.3+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 10, 2017 License: MIT Imports: 21 Imported by: 0

Documentation

Overview

Package monitor is a generated protocol buffer package.

It is generated from these files: 

github.com/TheThingsNetwork/ttn/api/monitor/monitor.proto

It has these top-level messages:

Index

Constants

This section is empty.

Variables

View Source 
var DefaultClientConfig = ClientConfig{
	BufferSize: 10,
}

DefaultClientConfig for monitor Client

View Source 
var DefaultDialOptions = []grpc.DialOption{
	grpc.WithBlock(),
	grpc.FailOnNonTempDialError(false),
	grpc.WithStreamInterceptor(restartstream.Interceptor(restartstream.DefaultSettings)),
}

DefaultDialOptions for connecting with a monitor server

View Source 
var TLSConfig *tls.Config

TLSConfig to use

Functions

func RegisterMonitorServer 

func RegisterMonitorServer(s *grpc.Server, srv MonitorServer)

Types

type Client 

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

Client for monitor

func NewClient 

func NewClient(config ClientConfig) *Client

NewClient creates a new Client with the given configuration

func (*Client) AddConn 

func (c *Client) AddConn(name string, conn *grpc.ClientConn)

AddConn adds a new monitor server on an existing connection This function should not be called after streams have been started

func (*Client) AddServer 

func (c *Client) AddServer(name, address string, opts ...grpc.DialOption)

AddServer adds a new monitor server. Supplying DialOptions overrides the default dial options. If the default DialOptions are used, TLS will be used to connect to monitors with a "-tls" suffix in their name. This function should not be called after streams have been started

func (*Client) Close 

func (c *Client) Close()

Close the client and all its connections

func (*Client) NewBrokerStreams 

func (c *Client) NewBrokerStreams(id string, token string) GenericStream

NewBrokerStreams returns new streams using the given broker ID and token

func (*Client) NewGatewayStreams 

func (c *Client) NewGatewayStreams(id string, token string) GenericStream

NewGatewayStreams returns new streams using the given gateway ID and token

type ClientConfig 

type ClientConfig struct {
	BufferSize int
}

ClientConfig for monitor Client

type GenericStream 

type GenericStream interface {
	Send(interface{})
	Close()
}

GenericStream is used for sending anything to the monitor. Depending on the context, this can be - *router.UplinkMessage - *router.DownlinkMessage - *gateway.Status - *broker.DeduplicatedUplinkMessage - *broker.DownlinkMessage

type MonitorClient 

type MonitorClient interface {
	GatewayStatus(ctx context.Context, opts ...grpc.CallOption) (Monitor_GatewayStatusClient, error)
	GatewayUplink(ctx context.Context, opts ...grpc.CallOption) (Monitor_GatewayUplinkClient, error)
	GatewayDownlink(ctx context.Context, opts ...grpc.CallOption) (Monitor_GatewayDownlinkClient, error)
	BrokerUplink(ctx context.Context, opts ...grpc.CallOption) (Monitor_BrokerUplinkClient, error)
	BrokerDownlink(ctx context.Context, opts ...grpc.CallOption) (Monitor_BrokerDownlinkClient, error)
}

func NewMonitorClient 

func NewMonitorClient(cc *grpc.ClientConn) MonitorClient

type MonitorServer 

type MonitorServer interface {
	GatewayStatus(Monitor_GatewayStatusServer) error
	GatewayUplink(Monitor_GatewayUplinkServer) error
	GatewayDownlink(Monitor_GatewayDownlinkServer) error
	BrokerUplink(Monitor_BrokerUplinkServer) error
	BrokerDownlink(Monitor_BrokerDownlinkServer) error
}

type Monitor_BrokerDownlinkClient 

type Monitor_BrokerDownlinkClient interface {
	Send(*broker.DownlinkMessage) error
	CloseAndRecv() (*google_protobuf1.Empty, error)
	grpc.ClientStream
}

type Monitor_BrokerDownlinkServer 

type Monitor_BrokerDownlinkServer interface {
	SendAndClose(*google_protobuf1.Empty) error
	Recv() (*broker.DownlinkMessage, error)
	grpc.ServerStream
}

type Monitor_BrokerUplinkClient 

type Monitor_BrokerUplinkClient interface {
	Send(*broker.DeduplicatedUplinkMessage) error
	CloseAndRecv() (*google_protobuf1.Empty, error)
	grpc.ClientStream
}

type Monitor_BrokerUplinkServer 

type Monitor_BrokerUplinkServer interface {
	SendAndClose(*google_protobuf1.Empty) error
	Recv() (*broker.DeduplicatedUplinkMessage, error)
	grpc.ServerStream
}

type Monitor_GatewayDownlinkClient 

type Monitor_GatewayDownlinkClient interface {
	Send(*router.DownlinkMessage) error
	CloseAndRecv() (*google_protobuf1.Empty, error)
	grpc.ClientStream
}

type Monitor_GatewayDownlinkServer 

type Monitor_GatewayDownlinkServer interface {
	SendAndClose(*google_protobuf1.Empty) error
	Recv() (*router.DownlinkMessage, error)
	grpc.ServerStream
}

type Monitor_GatewayStatusClient 

type Monitor_GatewayStatusClient interface {
	Send(*gateway.Status) error
	CloseAndRecv() (*google_protobuf1.Empty, error)
	grpc.ClientStream
}

type Monitor_GatewayStatusServer 

type Monitor_GatewayStatusServer interface {
	SendAndClose(*google_protobuf1.Empty) error
	Recv() (*gateway.Status, error)
	grpc.ServerStream
}

type Monitor_GatewayUplinkClient 

type Monitor_GatewayUplinkClient interface {
	Send(*router.UplinkMessage) error
	CloseAndRecv() (*google_protobuf1.Empty, error)
	grpc.ClientStream
}

type Monitor_GatewayUplinkServer 

type Monitor_GatewayUplinkServer interface {
	SendAndClose(*google_protobuf1.Empty) error
	Recv() (*router.UplinkMessage, error)
	grpc.ServerStream
}

type ReferenceMonitorServer 

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

ReferenceMonitorServer is a new reference monitor server

func NewReferenceMonitorServer 

func NewReferenceMonitorServer(bufferSize int) *ReferenceMonitorServer

NewReferenceMonitorServer creates a new reference monitor server 

func (s *ReferenceMonitorServer) BrokerDownlink(stream Monitor_BrokerDownlinkServer) error

BrokerDownlink RPC 

func (s *ReferenceMonitorServer) BrokerUplink(stream Monitor_BrokerUplinkServer) error

BrokerUplink RPC 

func (s *ReferenceMonitorServer) GatewayDownlink(stream Monitor_GatewayDownlinkServer) error

GatewayDownlink RPC

func (*ReferenceMonitorServer) GatewayStatus 

func (s *ReferenceMonitorServer) GatewayStatus(stream Monitor_GatewayStatusServer) (err error)

GatewayStatus RPC 

func (s *ReferenceMonitorServer) GatewayUplink(stream Monitor_GatewayUplinkServer) error

GatewayUplink RPC

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.