remote

type MQTTClient interface {
	// Sends the specified message to the specified topic.
	//
	// returns true if the message has been sent.
	SendMessage(ctx context.Context, in *Message, opts ...grpc.CallOption) (*SendMessageResult, error)
}

type MQTTServer interface {
	// Sends the specified message to the specified topic.
	//
	// returns true if the message has been sent.
	SendMessage(context.Context, *Message) (*SendMessageResult, error)
}

type Message struct {
	Topic    string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload  string `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Retained bool   `protobuf:"varint,3,opt,name=retained,proto3" json:"retained,omitempty"`
	// contains filtered or unexported fields
}

type SendMessageResult struct {
	Topic    string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Retained bool   `protobuf:"varint,2,opt,name=retained,proto3" json:"retained,omitempty"`
	// contains filtered or unexported fields
}

type Server struct {
	Debug      bool
	Port       int
	Host       string
	ConfigPath string
	Config     *viper.Viper
	Logger     log.FieldLogger
	MqttClient *mqttclient.MqttClient
	NewRelic   newrelic.Application
	// contains filtered or unexported fields
}

type UnimplementedMQTTServer struct {
}