pb

package
v0.0.0-...-f174eeb Latest Latest
Warning

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

Go to latest
Published: May 2, 2024 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DeviceHelper_Configure_FullMethodName = "/naisdevice.DeviceHelper/Configure"
	DeviceHelper_Teardown_FullMethodName  = "/naisdevice.DeviceHelper/Teardown"
	DeviceHelper_Upgrade_FullMethodName   = "/naisdevice.DeviceHelper/Upgrade"
	DeviceHelper_GetSerial_FullMethodName = "/naisdevice.DeviceHelper/GetSerial"
)
View Source
const (
	DeviceAgent_Status_FullMethodName                = "/naisdevice.DeviceAgent/Status"
	DeviceAgent_ConfigureJITA_FullMethodName         = "/naisdevice.DeviceAgent/ConfigureJITA"
	DeviceAgent_Login_FullMethodName                 = "/naisdevice.DeviceAgent/Login"
	DeviceAgent_Logout_FullMethodName                = "/naisdevice.DeviceAgent/Logout"
	DeviceAgent_SetActiveTenant_FullMethodName       = "/naisdevice.DeviceAgent/SetActiveTenant"
	DeviceAgent_SetAgentConfiguration_FullMethodName = "/naisdevice.DeviceAgent/SetAgentConfiguration"
	DeviceAgent_GetAgentConfiguration_FullMethodName = "/naisdevice.DeviceAgent/GetAgentConfiguration"
)
View Source
const (
	APIServer_Login_FullMethodName                   = "/naisdevice.APIServer/Login"
	APIServer_GetDeviceConfiguration_FullMethodName  = "/naisdevice.APIServer/GetDeviceConfiguration"
	APIServer_GetGatewayConfiguration_FullMethodName = "/naisdevice.APIServer/GetGatewayConfiguration"
	APIServer_GetGateway_FullMethodName              = "/naisdevice.APIServer/GetGateway"
	APIServer_ListGateways_FullMethodName            = "/naisdevice.APIServer/ListGateways"
	APIServer_EnrollGateway_FullMethodName           = "/naisdevice.APIServer/EnrollGateway"
	APIServer_UpdateGateway_FullMethodName           = "/naisdevice.APIServer/UpdateGateway"
	APIServer_GetSessions_FullMethodName             = "/naisdevice.APIServer/GetSessions"
)

Variables

View Source
var (
	AgentState_name = map[int32]string{
		0:  "Disconnected",
		1:  "Bootstrapping",
		2:  "Connected",
		3:  "Disconnecting",
		4:  "Unhealthy",
		5:  "Quitting",
		6:  "Authenticating",
		9:  "AuthenticateBackoff",
		10: "AgentConfigurationChanged",
	}
	AgentState_value = map[string]int32{
		"Disconnected":              0,
		"Bootstrapping":             1,
		"Connected":                 2,
		"Disconnecting":             3,
		"Unhealthy":                 4,
		"Quitting":                  5,
		"Authenticating":            6,
		"AuthenticateBackoff":       9,
		"AgentConfigurationChanged": 10,
	}
)

Enum value maps for AgentState.

View Source
var (
	DeviceConfigurationStatus_name = map[int32]string{
		0: "DeviceHealthy",
		1: "DeviceUnhealthy",
		2: "InvalidSession",
	}
	DeviceConfigurationStatus_value = map[string]int32{
		"DeviceHealthy":   0,
		"DeviceUnhealthy": 1,
		"InvalidSession":  2,
	}
)

Enum value maps for DeviceConfigurationStatus.

View Source
var (
	AuthProvider_name = map[int32]string{
		0: "Azure",
		1: "Google",
	}
	AuthProvider_value = map[string]int32{
		"Azure":  0,
		"Google": 1,
	}
)

Enum value maps for AuthProvider.

View Source
var APIServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "naisdevice.APIServer",
	HandlerType: (*APIServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Login",
			Handler:    _APIServer_Login_Handler,
		},
		{
			MethodName: "GetGateway",
			Handler:    _APIServer_GetGateway_Handler,
		},
		{
			MethodName: "EnrollGateway",
			Handler:    _APIServer_EnrollGateway_Handler,
		},
		{
			MethodName: "UpdateGateway",
			Handler:    _APIServer_UpdateGateway_Handler,
		},
		{
			MethodName: "GetSessions",
			Handler:    _APIServer_GetSessions_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetDeviceConfiguration",
			Handler:       _APIServer_GetDeviceConfiguration_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetGatewayConfiguration",
			Handler:       _APIServer_GetGatewayConfiguration_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListGateways",
			Handler:       _APIServer_ListGateways_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "internal/pb/protobuf-api.proto",
}

APIServer_ServiceDesc is the grpc.ServiceDesc for APIServer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var DeviceAgent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "naisdevice.DeviceAgent",
	HandlerType: (*DeviceAgentServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ConfigureJITA",
			Handler:    _DeviceAgent_ConfigureJITA_Handler,
		},
		{
			MethodName: "Login",
			Handler:    _DeviceAgent_Login_Handler,
		},
		{
			MethodName: "Logout",
			Handler:    _DeviceAgent_Logout_Handler,
		},
		{
			MethodName: "SetActiveTenant",
			Handler:    _DeviceAgent_SetActiveTenant_Handler,
		},
		{
			MethodName: "SetAgentConfiguration",
			Handler:    _DeviceAgent_SetAgentConfiguration_Handler,
		},
		{
			MethodName: "GetAgentConfiguration",
			Handler:    _DeviceAgent_GetAgentConfiguration_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Status",
			Handler:       _DeviceAgent_Status_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "internal/pb/protobuf-api.proto",
}

DeviceAgent_ServiceDesc is the grpc.ServiceDesc for DeviceAgent service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var DeviceHelper_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "naisdevice.DeviceHelper",
	HandlerType: (*DeviceHelperServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Configure",
			Handler:    _DeviceHelper_Configure_Handler,
		},
		{
			MethodName: "Teardown",
			Handler:    _DeviceHelper_Teardown_Handler,
		},
		{
			MethodName: "Upgrade",
			Handler:    _DeviceHelper_Upgrade_Handler,
		},
		{
			MethodName: "GetSerial",
			Handler:    _DeviceHelper_GetSerial_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/pb/protobuf-api.proto",
}

DeviceHelper_ServiceDesc is the grpc.ServiceDesc for DeviceHelper service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_internal_pb_protobuf_api_proto protoreflect.FileDescriptor

Functions

func RegisterAPIServerServer

func RegisterAPIServerServer(s grpc.ServiceRegistrar, srv APIServerServer)

func RegisterDeviceAgentServer

func RegisterDeviceAgentServer(s grpc.ServiceRegistrar, srv DeviceAgentServer)

func RegisterDeviceHelperServer

func RegisterDeviceHelperServer(s grpc.ServiceRegistrar, srv DeviceHelperServer)

Types

type APIServerClient

type APIServerClient interface {
	// Exchange an access token for a session
	Login(ctx context.Context, in *APIServerLoginRequest, opts ...grpc.CallOption) (*APIServerLoginResponse, error)
	// Set up a client->server request for continuous streaming of new configuration
	GetDeviceConfiguration(ctx context.Context, in *GetDeviceConfigurationRequest, opts ...grpc.CallOption) (APIServer_GetDeviceConfigurationClient, error)
	// Set up continuous streaming of new gateway configuration
	GetGatewayConfiguration(ctx context.Context, in *GetGatewayConfigurationRequest, opts ...grpc.CallOption) (APIServer_GetGatewayConfigurationClient, error)
	// Admin endpoint for retrieving a single gateway
	GetGateway(ctx context.Context, in *ModifyGatewayRequest, opts ...grpc.CallOption) (*Gateway, error)
	// Admin endpoint for listing out gateways registered in database
	ListGateways(ctx context.Context, in *ListGatewayRequest, opts ...grpc.CallOption) (APIServer_ListGatewaysClient, error)
	// Admin endpoint for adding gateway credentials to the database
	EnrollGateway(ctx context.Context, in *ModifyGatewayRequest, opts ...grpc.CallOption) (*ModifyGatewayResponse, error)
	// Admin endpoint for adding gateway credentials to the database
	UpdateGateway(ctx context.Context, in *ModifyGatewayRequest, opts ...grpc.CallOption) (*ModifyGatewayResponse, error)
	// Admin endpoint for reading sessions from the cache
	GetSessions(ctx context.Context, in *GetSessionsRequest, opts ...grpc.CallOption) (*GetSessionsResponse, error)
}

APIServerClient is the client API for APIServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAPIServerClient

func NewAPIServerClient(cc grpc.ClientConnInterface) APIServerClient

type APIServerLoginRequest

type APIServerLoginRequest struct {
	Token    string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Platform string `protobuf:"bytes,2,opt,name=platform,proto3" json:"platform,omitempty"`
	Serial   string `protobuf:"bytes,3,opt,name=serial,proto3" json:"serial,omitempty"`
	Version  string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*APIServerLoginRequest) Descriptor deprecated

func (*APIServerLoginRequest) Descriptor() ([]byte, []int)

Deprecated: Use APIServerLoginRequest.ProtoReflect.Descriptor instead.

func (*APIServerLoginRequest) GetPlatform

func (x *APIServerLoginRequest) GetPlatform() string

func (*APIServerLoginRequest) GetSerial

func (x *APIServerLoginRequest) GetSerial() string

func (*APIServerLoginRequest) GetToken

func (x *APIServerLoginRequest) GetToken() string

func (*APIServerLoginRequest) GetVersion

func (x *APIServerLoginRequest) GetVersion() string

func (*APIServerLoginRequest) ProtoMessage

func (*APIServerLoginRequest) ProtoMessage()

func (*APIServerLoginRequest) ProtoReflect

func (x *APIServerLoginRequest) ProtoReflect() protoreflect.Message

func (*APIServerLoginRequest) Reset

func (x *APIServerLoginRequest) Reset()

func (*APIServerLoginRequest) String

func (x *APIServerLoginRequest) String() string

type APIServerLoginResponse

type APIServerLoginResponse struct {
	Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*APIServerLoginResponse) Descriptor deprecated

func (*APIServerLoginResponse) Descriptor() ([]byte, []int)

Deprecated: Use APIServerLoginResponse.ProtoReflect.Descriptor instead.

func (*APIServerLoginResponse) GetSession

func (x *APIServerLoginResponse) GetSession() *Session

func (*APIServerLoginResponse) ProtoMessage

func (*APIServerLoginResponse) ProtoMessage()

func (*APIServerLoginResponse) ProtoReflect

func (x *APIServerLoginResponse) ProtoReflect() protoreflect.Message

func (*APIServerLoginResponse) Reset

func (x *APIServerLoginResponse) Reset()

func (*APIServerLoginResponse) String

func (x *APIServerLoginResponse) String() string

type APIServerServer

type APIServerServer interface {
	// Exchange an access token for a session
	Login(context.Context, *APIServerLoginRequest) (*APIServerLoginResponse, error)
	// Set up a client->server request for continuous streaming of new configuration
	GetDeviceConfiguration(*GetDeviceConfigurationRequest, APIServer_GetDeviceConfigurationServer) error
	// Set up continuous streaming of new gateway configuration
	GetGatewayConfiguration(*GetGatewayConfigurationRequest, APIServer_GetGatewayConfigurationServer) error
	// Admin endpoint for retrieving a single gateway
	GetGateway(context.Context, *ModifyGatewayRequest) (*Gateway, error)
	// Admin endpoint for listing out gateways registered in database
	ListGateways(*ListGatewayRequest, APIServer_ListGatewaysServer) error
	// Admin endpoint for adding gateway credentials to the database
	EnrollGateway(context.Context, *ModifyGatewayRequest) (*ModifyGatewayResponse, error)
	// Admin endpoint for adding gateway credentials to the database
	UpdateGateway(context.Context, *ModifyGatewayRequest) (*ModifyGatewayResponse, error)
	// Admin endpoint for reading sessions from the cache
	GetSessions(context.Context, *GetSessionsRequest) (*GetSessionsResponse, error)
	// contains filtered or unexported methods
}

APIServerServer is the server API for APIServer service. All implementations must embed UnimplementedAPIServerServer for forward compatibility

type APIServer_GetDeviceConfigurationClient

type APIServer_GetDeviceConfigurationClient interface {
	Recv() (*GetDeviceConfigurationResponse, error)
	grpc.ClientStream
}

type APIServer_GetDeviceConfigurationServer

type APIServer_GetDeviceConfigurationServer interface {
	Send(*GetDeviceConfigurationResponse) error
	grpc.ServerStream
}

type APIServer_GetGatewayConfigurationClient

type APIServer_GetGatewayConfigurationClient interface {
	Recv() (*GetGatewayConfigurationResponse, error)
	grpc.ClientStream
}

type APIServer_GetGatewayConfigurationServer

type APIServer_GetGatewayConfigurationServer interface {
	Send(*GetGatewayConfigurationResponse) error
	grpc.ServerStream
}

type APIServer_ListGatewaysClient

type APIServer_ListGatewaysClient interface {
	Recv() (*Gateway, error)
	grpc.ClientStream
}

type APIServer_ListGatewaysServer

type APIServer_ListGatewaysServer interface {
	Send(*Gateway) error
	grpc.ServerStream
}

type AgentConfiguration

type AgentConfiguration struct {
	AutoConnect           bool `protobuf:"varint,2,opt,name=AutoConnect,proto3" json:"AutoConnect,omitempty"`
	ILoveNinetiesBoybands bool `protobuf:"varint,3,opt,name=ILoveNinetiesBoybands,proto3" json:"ILoveNinetiesBoybands,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentConfiguration) Descriptor deprecated

func (*AgentConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use AgentConfiguration.ProtoReflect.Descriptor instead.

func (*AgentConfiguration) GetAutoConnect

func (x *AgentConfiguration) GetAutoConnect() bool

func (*AgentConfiguration) GetILoveNinetiesBoybands

func (x *AgentConfiguration) GetILoveNinetiesBoybands() bool

func (*AgentConfiguration) ProtoMessage

func (*AgentConfiguration) ProtoMessage()

func (*AgentConfiguration) ProtoReflect

func (x *AgentConfiguration) ProtoReflect() protoreflect.Message

func (*AgentConfiguration) Reset

func (x *AgentConfiguration) Reset()

func (*AgentConfiguration) String

func (x *AgentConfiguration) String() string

type AgentState

type AgentState int32
const (
	AgentState_Disconnected              AgentState = 0
	AgentState_Bootstrapping             AgentState = 1
	AgentState_Connected                 AgentState = 2
	AgentState_Disconnecting             AgentState = 3
	AgentState_Unhealthy                 AgentState = 4
	AgentState_Quitting                  AgentState = 5
	AgentState_Authenticating            AgentState = 6
	AgentState_AuthenticateBackoff       AgentState = 9
	AgentState_AgentConfigurationChanged AgentState = 10
)

func (AgentState) Descriptor

func (AgentState) Descriptor() protoreflect.EnumDescriptor

func (AgentState) Enum

func (x AgentState) Enum() *AgentState

func (AgentState) EnumDescriptor deprecated

func (AgentState) EnumDescriptor() ([]byte, []int)

Deprecated: Use AgentState.Descriptor instead.

func (AgentState) Number

func (x AgentState) Number() protoreflect.EnumNumber

func (AgentState) String

func (x AgentState) String() string

func (AgentState) Type

type AgentStatus

type AgentStatus struct {
	ConnectionState     AgentState             `protobuf:"varint,1,opt,name=connectionState,proto3,enum=naisdevice.AgentState" json:"connectionState,omitempty"`
	ConnectedSince      *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=connectedSince,proto3" json:"connectedSince,omitempty"`
	NewVersionAvailable bool                   `protobuf:"varint,3,opt,name=newVersionAvailable,proto3" json:"newVersionAvailable,omitempty"`
	Gateways            []*Gateway             `protobuf:"bytes,4,rep,name=Gateways,proto3" json:"Gateways,omitempty"`
	Tenants             []*Tenant              `protobuf:"bytes,5,rep,name=Tenants,proto3" json:"Tenants,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentStatus) ConnectionStateString

func (x *AgentStatus) ConnectionStateString() string

Human-friendly connection status

func (*AgentStatus) Descriptor deprecated

func (*AgentStatus) Descriptor() ([]byte, []int)

Deprecated: Use AgentStatus.ProtoReflect.Descriptor instead.

func (*AgentStatus) GetConnectedSince

func (x *AgentStatus) GetConnectedSince() *timestamppb.Timestamp

func (*AgentStatus) GetConnectionState

func (x *AgentStatus) GetConnectionState() AgentState

func (*AgentStatus) GetGateways

func (x *AgentStatus) GetGateways() []*Gateway

func (*AgentStatus) GetNewVersionAvailable

func (x *AgentStatus) GetNewVersionAvailable() bool

func (*AgentStatus) GetTenants

func (x *AgentStatus) GetTenants() []*Tenant

func (*AgentStatus) ProtoMessage

func (*AgentStatus) ProtoMessage()

func (*AgentStatus) ProtoReflect

func (x *AgentStatus) ProtoReflect() protoreflect.Message

func (*AgentStatus) Reset

func (x *AgentStatus) Reset()

func (*AgentStatus) String

func (x *AgentStatus) String() string

type AgentStatusRequest

type AgentStatusRequest struct {
	KeepConnectionOnComplete bool `protobuf:"varint,1,opt,name=keepConnectionOnComplete,proto3" json:"keepConnectionOnComplete,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentStatusRequest) Descriptor deprecated

func (*AgentStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use AgentStatusRequest.ProtoReflect.Descriptor instead.

func (*AgentStatusRequest) GetKeepConnectionOnComplete

func (x *AgentStatusRequest) GetKeepConnectionOnComplete() bool

func (*AgentStatusRequest) ProtoMessage

func (*AgentStatusRequest) ProtoMessage()

func (*AgentStatusRequest) ProtoReflect

func (x *AgentStatusRequest) ProtoReflect() protoreflect.Message

func (*AgentStatusRequest) Reset

func (x *AgentStatusRequest) Reset()

func (*AgentStatusRequest) String

func (x *AgentStatusRequest) String() string

type AuthProvider

type AuthProvider int32
const (
	AuthProvider_Azure  AuthProvider = 0
	AuthProvider_Google AuthProvider = 1
)

func (AuthProvider) Descriptor

func (AuthProvider) Enum

func (x AuthProvider) Enum() *AuthProvider

func (AuthProvider) EnumDescriptor deprecated

func (AuthProvider) EnumDescriptor() ([]byte, []int)

Deprecated: Use AuthProvider.Descriptor instead.

func (AuthProvider) Number

func (AuthProvider) String

func (x AuthProvider) String() string

func (AuthProvider) Type

type Configuration

type Configuration struct {
	PrivateKey string     `protobuf:"bytes,1,opt,name=privateKey,proto3" json:"privateKey,omitempty"`
	DeviceIPv4 string     `protobuf:"bytes,2,opt,name=deviceIPv4,proto3" json:"deviceIPv4,omitempty"`
	Gateways   []*Gateway `protobuf:"bytes,3,rep,name=Gateways,proto3" json:"Gateways,omitempty"`
	DeviceIPv6 string     `protobuf:"bytes,4,opt,name=deviceIPv6,proto3" json:"deviceIPv6,omitempty"`
	// contains filtered or unexported fields
}

func (*Configuration) Descriptor deprecated

func (*Configuration) Descriptor() ([]byte, []int)

Deprecated: Use Configuration.ProtoReflect.Descriptor instead.

func (*Configuration) GetDeviceIPv4

func (x *Configuration) GetDeviceIPv4() string

func (*Configuration) GetDeviceIPv6

func (x *Configuration) GetDeviceIPv6() string

func (*Configuration) GetGateways

func (x *Configuration) GetGateways() []*Gateway

func (*Configuration) GetPrivateKey

func (x *Configuration) GetPrivateKey() string

func (*Configuration) ProtoMessage

func (*Configuration) ProtoMessage()

func (*Configuration) ProtoReflect

func (x *Configuration) ProtoReflect() protoreflect.Message

func (*Configuration) Reset

func (x *Configuration) Reset()

func (*Configuration) String

func (x *Configuration) String() string

type ConfigureJITARequest

type ConfigureJITARequest struct {
	Gateway *Gateway `protobuf:"bytes,1,opt,name=gateway,proto3" json:"gateway,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigureJITARequest) Descriptor deprecated

func (*ConfigureJITARequest) Descriptor() ([]byte, []int)

Deprecated: Use ConfigureJITARequest.ProtoReflect.Descriptor instead.

func (*ConfigureJITARequest) GetGateway

func (x *ConfigureJITARequest) GetGateway() *Gateway

func (*ConfigureJITARequest) ProtoMessage

func (*ConfigureJITARequest) ProtoMessage()

func (*ConfigureJITARequest) ProtoReflect

func (x *ConfigureJITARequest) ProtoReflect() protoreflect.Message

func (*ConfigureJITARequest) Reset

func (x *ConfigureJITARequest) Reset()

func (*ConfigureJITARequest) String

func (x *ConfigureJITARequest) String() string

type ConfigureJITAResponse

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

func (*ConfigureJITAResponse) Descriptor deprecated

func (*ConfigureJITAResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConfigureJITAResponse.ProtoReflect.Descriptor instead.

func (*ConfigureJITAResponse) ProtoMessage

func (*ConfigureJITAResponse) ProtoMessage()

func (*ConfigureJITAResponse) ProtoReflect

func (x *ConfigureJITAResponse) ProtoReflect() protoreflect.Message

func (*ConfigureJITAResponse) Reset

func (x *ConfigureJITAResponse) Reset()

func (*ConfigureJITAResponse) String

func (x *ConfigureJITAResponse) String() string

type ConfigureResponse

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

func (*ConfigureResponse) Descriptor deprecated

func (*ConfigureResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConfigureResponse.ProtoReflect.Descriptor instead.

func (*ConfigureResponse) ProtoMessage

func (*ConfigureResponse) ProtoMessage()

func (*ConfigureResponse) ProtoReflect

func (x *ConfigureResponse) ProtoReflect() protoreflect.Message

func (*ConfigureResponse) Reset

func (x *ConfigureResponse) Reset()

func (*ConfigureResponse) String

func (x *ConfigureResponse) String() string

type ConnectionNotifier

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

ConnectionNotifier implements gRPC stats.Handler and provides the two channels Connect() and Disconnect() to notify when gRPC connections are set up and torn down.

Add to gRPC server with:

notifier := NewConnectionNotifier()
grpc.NewServer(grpc.StatsHandler(notifier))

Listen for events with:

<- notifier.Connect()
<- notifier.Disconnect()

func NewConnectionNotifier

func NewConnectionNotifier() *ConnectionNotifier

func (*ConnectionNotifier) Connect

func (h *ConnectionNotifier) Connect() <-chan interface{}

func (*ConnectionNotifier) Disconnect

func (h *ConnectionNotifier) Disconnect() <-chan interface{}

func (*ConnectionNotifier) HandleConn

func (h *ConnectionNotifier) HandleConn(ctx context.Context, s stats.ConnStats)

func (*ConnectionNotifier) HandleRPC

func (h *ConnectionNotifier) HandleRPC(ctx context.Context, s stats.RPCStats)

func (*ConnectionNotifier) TagConn

func (*ConnectionNotifier) TagRPC

type Device

type Device struct {
	Id          int64                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Serial      string                 `protobuf:"bytes,2,opt,name=serial,proto3" json:"serial,omitempty"`
	LastUpdated *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=lastUpdated,proto3" json:"lastUpdated,omitempty"`
	Healthy     bool                   `protobuf:"varint,6,opt,name=healthy,proto3" json:"healthy,omitempty"`
	PublicKey   string                 `protobuf:"bytes,7,opt,name=publicKey,proto3" json:"publicKey,omitempty"`
	Ipv4        string                 `protobuf:"bytes,8,opt,name=ipv4,proto3" json:"ipv4,omitempty"`
	Username    string                 `protobuf:"bytes,9,opt,name=username,proto3" json:"username,omitempty"`
	Platform    string                 `protobuf:"bytes,10,opt,name=platform,proto3" json:"platform,omitempty"`
	Ipv6        string                 `protobuf:"bytes,11,opt,name=ipv6,proto3" json:"ipv6,omitempty"`
	// contains filtered or unexported fields
}

func (*Device) Descriptor deprecated

func (*Device) Descriptor() ([]byte, []int)

Deprecated: Use Device.ProtoReflect.Descriptor instead.

func (*Device) GetAllowedIPs

func (x *Device) GetAllowedIPs() []string

Satisfy WireGuard interface. This field contains the private IP addresses of a device.

func (*Device) GetEndpoint

func (x *Device) GetEndpoint() string

Satisfy WireGuard interface. Endpoints are not used when configuring gateway and api server; connections are initiated from the client.

func (*Device) GetHealthy

func (x *Device) GetHealthy() bool

func (*Device) GetId

func (x *Device) GetId() int64

func (*Device) GetIpv4

func (x *Device) GetIpv4() string

func (*Device) GetIpv6

func (x *Device) GetIpv6() string

func (*Device) GetLastUpdated

func (x *Device) GetLastUpdated() *timestamppb.Timestamp

func (*Device) GetName

func (x *Device) GetName() string

Satisfy WireGuard interface. This value is written to the config file as a comment, so we put in the serial of the device in order to identify it.

func (*Device) GetPlatform

func (x *Device) GetPlatform() string

func (*Device) GetPublicKey

func (x *Device) GetPublicKey() string

func (*Device) GetSerial

func (x *Device) GetSerial() string

func (*Device) GetUsername

func (x *Device) GetUsername() string

func (*Device) ProtoMessage

func (*Device) ProtoMessage()

func (*Device) ProtoReflect

func (x *Device) ProtoReflect() protoreflect.Message

func (*Device) Reset

func (x *Device) Reset()

func (*Device) String

func (x *Device) String() string

type DeviceAgentClient

type DeviceAgentClient interface {
	// DeviceAgent will stream all state changes on this endpoint.
	// Use Status() to continuously monitor the current Agent status.
	Status(ctx context.Context, in *AgentStatusRequest, opts ...grpc.CallOption) (DeviceAgent_StatusClient, error)
	// Open the JITA form in a web browser.
	ConfigureJITA(ctx context.Context, in *ConfigureJITARequest, opts ...grpc.CallOption) (*ConfigureJITAResponse, error)
	// Log in to API server, enabling access to protected resources.
	Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error)
	// Log out of API server, shutting down all VPN connections.
	Logout(ctx context.Context, in *LogoutRequest, opts ...grpc.CallOption) (*LogoutResponse, error)
	// Set active tenant
	SetActiveTenant(ctx context.Context, in *SetActiveTenantRequest, opts ...grpc.CallOption) (*SetActiveTenantResponse, error)
	// Set device agent configuration
	SetAgentConfiguration(ctx context.Context, in *SetAgentConfigurationRequest, opts ...grpc.CallOption) (*SetAgentConfigurationResponse, error)
	// Get the current configuration for the device agent
	GetAgentConfiguration(ctx context.Context, in *GetAgentConfigurationRequest, opts ...grpc.CallOption) (*GetAgentConfigurationResponse, error)
}

DeviceAgentClient is the client API for DeviceAgent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type DeviceAgentServer

type DeviceAgentServer interface {
	// DeviceAgent will stream all state changes on this endpoint.
	// Use Status() to continuously monitor the current Agent status.
	Status(*AgentStatusRequest, DeviceAgent_StatusServer) error
	// Open the JITA form in a web browser.
	ConfigureJITA(context.Context, *ConfigureJITARequest) (*ConfigureJITAResponse, error)
	// Log in to API server, enabling access to protected resources.
	Login(context.Context, *LoginRequest) (*LoginResponse, error)
	// Log out of API server, shutting down all VPN connections.
	Logout(context.Context, *LogoutRequest) (*LogoutResponse, error)
	// Set active tenant
	SetActiveTenant(context.Context, *SetActiveTenantRequest) (*SetActiveTenantResponse, error)
	// Set device agent configuration
	SetAgentConfiguration(context.Context, *SetAgentConfigurationRequest) (*SetAgentConfigurationResponse, error)
	// Get the current configuration for the device agent
	GetAgentConfiguration(context.Context, *GetAgentConfigurationRequest) (*GetAgentConfigurationResponse, error)
	// contains filtered or unexported methods
}

DeviceAgentServer is the server API for DeviceAgent service. All implementations must embed UnimplementedDeviceAgentServer for forward compatibility

type DeviceAgent_StatusClient

type DeviceAgent_StatusClient interface {
	Recv() (*AgentStatus, error)
	grpc.ClientStream
}

type DeviceAgent_StatusServer

type DeviceAgent_StatusServer interface {
	Send(*AgentStatus) error
	grpc.ServerStream
}

type DeviceConfigurationStatus

type DeviceConfigurationStatus int32
const (
	DeviceConfigurationStatus_DeviceHealthy   DeviceConfigurationStatus = 0
	DeviceConfigurationStatus_DeviceUnhealthy DeviceConfigurationStatus = 1
	DeviceConfigurationStatus_InvalidSession  DeviceConfigurationStatus = 2
)

func (DeviceConfigurationStatus) Descriptor

func (DeviceConfigurationStatus) Enum

func (DeviceConfigurationStatus) EnumDescriptor deprecated

func (DeviceConfigurationStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use DeviceConfigurationStatus.Descriptor instead.

func (DeviceConfigurationStatus) Number

func (DeviceConfigurationStatus) String

func (x DeviceConfigurationStatus) String() string

func (DeviceConfigurationStatus) Type

type DeviceHelperClient

type DeviceHelperClient interface {
	// Push and apply new VPN configuration.
	Configure(ctx context.Context, in *Configuration, opts ...grpc.CallOption) (*ConfigureResponse, error)
	// Delete VPN configuration and shut down connections.
	Teardown(ctx context.Context, in *TeardownRequest, opts ...grpc.CallOption) (*TeardownResponse, error)
	// Install the newest version of naisdevice.
	Upgrade(ctx context.Context, in *UpgradeRequest, opts ...grpc.CallOption) (*UpgradeResponse, error)
	GetSerial(ctx context.Context, in *GetSerialRequest, opts ...grpc.CallOption) (*GetSerialResponse, error)
}

DeviceHelperClient is the client API for DeviceHelper service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type DeviceHelperServer

type DeviceHelperServer interface {
	// Push and apply new VPN configuration.
	Configure(context.Context, *Configuration) (*ConfigureResponse, error)
	// Delete VPN configuration and shut down connections.
	Teardown(context.Context, *TeardownRequest) (*TeardownResponse, error)
	// Install the newest version of naisdevice.
	Upgrade(context.Context, *UpgradeRequest) (*UpgradeResponse, error)
	GetSerial(context.Context, *GetSerialRequest) (*GetSerialResponse, error)
	// contains filtered or unexported methods
}

DeviceHelperServer is the server API for DeviceHelper service. All implementations must embed UnimplementedDeviceHelperServer for forward compatibility

type Error

type Error struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated

func (*Error) Descriptor() ([]byte, []int)

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetMessage

func (x *Error) GetMessage() string

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) ProtoReflect

func (x *Error) ProtoReflect() protoreflect.Message

func (*Error) Reset

func (x *Error) Reset()

func (*Error) String

func (x *Error) String() string

type Gateway

type Gateway struct {
	Name                     string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Healthy                  bool     `protobuf:"varint,2,opt,name=healthy,proto3" json:"healthy,omitempty"`
	PublicKey                string   `protobuf:"bytes,3,opt,name=publicKey,proto3" json:"publicKey,omitempty"`
	Endpoint                 string   `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Ipv4                     string   `protobuf:"bytes,5,opt,name=ipv4,proto3" json:"ipv4,omitempty"`
	RoutesIPv4               []string `protobuf:"bytes,6,rep,name=routesIPv4,proto3" json:"routesIPv4,omitempty"`
	RoutesIPv6               []string `protobuf:"bytes,11,rep,name=routesIPv6,proto3" json:"routesIPv6,omitempty"`
	RequiresPrivilegedAccess bool     `` /* 134-byte string literal not displayed */
	AccessGroupIDs           []string `protobuf:"bytes,8,rep,name=accessGroupIDs,proto3" json:"accessGroupIDs,omitempty"`
	PasswordHash             string   `protobuf:"bytes,9,opt,name=passwordHash,proto3" json:"passwordHash,omitempty"`
	Ipv6                     string   `protobuf:"bytes,10,opt,name=ipv6,proto3" json:"ipv6,omitempty"`
	// contains filtered or unexported fields
}

func MergeGatewayHealth

func MergeGatewayHealth(existingGateways []*Gateway, newGateways []*Gateway) []*Gateway

MergeGatewayHealth copies the `Healthy` member from the existingGateways slice (if available), and returns updated new gateways.

func (*Gateway) Descriptor deprecated

func (*Gateway) Descriptor() ([]byte, []int)

Deprecated: Use Gateway.ProtoReflect.Descriptor instead.

func (*Gateway) GetAccessGroupIDs

func (x *Gateway) GetAccessGroupIDs() []string

func (*Gateway) GetAllowedIPs

func (x *Gateway) GetAllowedIPs() []string

Satisfy WireGuard interface. IP addresses routed by a gateway includes configured routes plus the gateway itself.

func (*Gateway) GetEndpoint

func (x *Gateway) GetEndpoint() string

func (*Gateway) GetHealthy

func (x *Gateway) GetHealthy() bool

func (*Gateway) GetIpv4

func (x *Gateway) GetIpv4() string

func (*Gateway) GetIpv6

func (x *Gateway) GetIpv6() string

func (*Gateway) GetName

func (x *Gateway) GetName() string

func (*Gateway) GetPasswordHash

func (x *Gateway) GetPasswordHash() string

func (*Gateway) GetPublicKey

func (x *Gateway) GetPublicKey() string

func (*Gateway) GetRequiresPrivilegedAccess

func (x *Gateway) GetRequiresPrivilegedAccess() bool

func (*Gateway) GetRoutesIPv4

func (x *Gateway) GetRoutesIPv4() []string

func (*Gateway) GetRoutesIPv6

func (x *Gateway) GetRoutesIPv6() []string

func (*Gateway) MergeHealth

func (x *Gateway) MergeHealth(y *Gateway)

func (*Gateway) ProtoMessage

func (*Gateway) ProtoMessage()

func (*Gateway) ProtoReflect

func (x *Gateway) ProtoReflect() protoreflect.Message

func (*Gateway) Reset

func (x *Gateway) Reset()

func (*Gateway) String

func (x *Gateway) String() string

type GetAgentConfigurationRequest

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

func (*GetAgentConfigurationRequest) Descriptor deprecated

func (*GetAgentConfigurationRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetAgentConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetAgentConfigurationRequest) ProtoMessage

func (*GetAgentConfigurationRequest) ProtoMessage()

func (*GetAgentConfigurationRequest) ProtoReflect

func (*GetAgentConfigurationRequest) Reset

func (x *GetAgentConfigurationRequest) Reset()

func (*GetAgentConfigurationRequest) String

type GetAgentConfigurationResponse

type GetAgentConfigurationResponse struct {
	Config *AgentConfiguration `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAgentConfigurationResponse) Descriptor deprecated

func (*GetAgentConfigurationResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetAgentConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetAgentConfigurationResponse) GetConfig

func (*GetAgentConfigurationResponse) ProtoMessage

func (*GetAgentConfigurationResponse) ProtoMessage()

func (*GetAgentConfigurationResponse) ProtoReflect

func (*GetAgentConfigurationResponse) Reset

func (x *GetAgentConfigurationResponse) Reset()

func (*GetAgentConfigurationResponse) String

type GetDeviceConfigurationRequest

type GetDeviceConfigurationRequest struct {
	SessionKey string `protobuf:"bytes,1,opt,name=sessionKey,proto3" json:"sessionKey,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDeviceConfigurationRequest) Descriptor deprecated

func (*GetDeviceConfigurationRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetDeviceConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetDeviceConfigurationRequest) GetSessionKey

func (x *GetDeviceConfigurationRequest) GetSessionKey() string

func (*GetDeviceConfigurationRequest) ProtoMessage

func (*GetDeviceConfigurationRequest) ProtoMessage()

func (*GetDeviceConfigurationRequest) ProtoReflect

func (*GetDeviceConfigurationRequest) Reset

func (x *GetDeviceConfigurationRequest) Reset()

func (*GetDeviceConfigurationRequest) String

type GetDeviceConfigurationResponse

type GetDeviceConfigurationResponse struct {
	Status   DeviceConfigurationStatus `protobuf:"varint,1,opt,name=status,proto3,enum=naisdevice.DeviceConfigurationStatus" json:"status,omitempty"`
	Gateways []*Gateway                `protobuf:"bytes,2,rep,name=Gateways,proto3" json:"Gateways,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDeviceConfigurationResponse) Descriptor deprecated

func (*GetDeviceConfigurationResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetDeviceConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetDeviceConfigurationResponse) GetGateways

func (x *GetDeviceConfigurationResponse) GetGateways() []*Gateway

func (*GetDeviceConfigurationResponse) GetStatus

func (*GetDeviceConfigurationResponse) ProtoMessage

func (*GetDeviceConfigurationResponse) ProtoMessage()

func (*GetDeviceConfigurationResponse) ProtoReflect

func (*GetDeviceConfigurationResponse) Reset

func (x *GetDeviceConfigurationResponse) Reset()

func (*GetDeviceConfigurationResponse) String

type GetGatewayConfigurationRequest

type GetGatewayConfigurationRequest struct {
	Gateway  string `protobuf:"bytes,1,opt,name=gateway,proto3" json:"gateway,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGatewayConfigurationRequest) Descriptor deprecated

func (*GetGatewayConfigurationRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetGatewayConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetGatewayConfigurationRequest) GetGateway

func (x *GetGatewayConfigurationRequest) GetGateway() string

func (*GetGatewayConfigurationRequest) GetPassword

func (x *GetGatewayConfigurationRequest) GetPassword() string

func (*GetGatewayConfigurationRequest) ProtoMessage

func (*GetGatewayConfigurationRequest) ProtoMessage()

func (*GetGatewayConfigurationRequest) ProtoReflect

func (*GetGatewayConfigurationRequest) Reset

func (x *GetGatewayConfigurationRequest) Reset()

func (*GetGatewayConfigurationRequest) String

type GetGatewayConfigurationResponse

type GetGatewayConfigurationResponse struct {
	Devices    []*Device `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"`
	RoutesIPv4 []string  `protobuf:"bytes,2,rep,name=routesIPv4,proto3" json:"routesIPv4,omitempty"`
	RoutesIPv6 []string  `protobuf:"bytes,3,rep,name=routesIPv6,proto3" json:"routesIPv6,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGatewayConfigurationResponse) Descriptor deprecated

func (*GetGatewayConfigurationResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetGatewayConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetGatewayConfigurationResponse) GetDevices

func (x *GetGatewayConfigurationResponse) GetDevices() []*Device

func (*GetGatewayConfigurationResponse) GetRoutesIPv4

func (x *GetGatewayConfigurationResponse) GetRoutesIPv4() []string

func (*GetGatewayConfigurationResponse) GetRoutesIPv6

func (x *GetGatewayConfigurationResponse) GetRoutesIPv6() []string

func (*GetGatewayConfigurationResponse) ProtoMessage

func (*GetGatewayConfigurationResponse) ProtoMessage()

func (*GetGatewayConfigurationResponse) ProtoReflect

func (*GetGatewayConfigurationResponse) Reset

func (*GetGatewayConfigurationResponse) String

type GetSerialRequest

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

func (*GetSerialRequest) Descriptor deprecated

func (*GetSerialRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSerialRequest.ProtoReflect.Descriptor instead.

func (*GetSerialRequest) ProtoMessage

func (*GetSerialRequest) ProtoMessage()

func (*GetSerialRequest) ProtoReflect

func (x *GetSerialRequest) ProtoReflect() protoreflect.Message

func (*GetSerialRequest) Reset

func (x *GetSerialRequest) Reset()

func (*GetSerialRequest) String

func (x *GetSerialRequest) String() string

type GetSerialResponse

type GetSerialResponse struct {
	Serial string `protobuf:"bytes,1,opt,name=serial,proto3" json:"serial,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSerialResponse) Descriptor deprecated

func (*GetSerialResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetSerialResponse.ProtoReflect.Descriptor instead.

func (*GetSerialResponse) GetSerial

func (x *GetSerialResponse) GetSerial() string

func (*GetSerialResponse) ProtoMessage

func (*GetSerialResponse) ProtoMessage()

func (*GetSerialResponse) ProtoReflect

func (x *GetSerialResponse) ProtoReflect() protoreflect.Message

func (*GetSerialResponse) Reset

func (x *GetSerialResponse) Reset()

func (*GetSerialResponse) String

func (x *GetSerialResponse) String() string

type GetSessionsRequest

type GetSessionsRequest struct {
	Password string `protobuf:"bytes,1,opt,name=password,proto3" json:"password,omitempty"`
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSessionsRequest) Descriptor deprecated

func (*GetSessionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetSessionsRequest.ProtoReflect.Descriptor instead.

func (*GetSessionsRequest) GetPassword

func (x *GetSessionsRequest) GetPassword() string

func (*GetSessionsRequest) GetUsername

func (x *GetSessionsRequest) GetUsername() string

func (*GetSessionsRequest) ProtoMessage

func (*GetSessionsRequest) ProtoMessage()

func (*GetSessionsRequest) ProtoReflect

func (x *GetSessionsRequest) ProtoReflect() protoreflect.Message

func (*GetSessionsRequest) Reset

func (x *GetSessionsRequest) Reset()

func (*GetSessionsRequest) String

func (x *GetSessionsRequest) String() string

type GetSessionsResponse

type GetSessionsResponse struct {
	Sessions []*Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSessionsResponse) Descriptor deprecated

func (*GetSessionsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetSessionsResponse.ProtoReflect.Descriptor instead.

func (*GetSessionsResponse) GetSessions

func (x *GetSessionsResponse) GetSessions() []*Session

func (*GetSessionsResponse) ProtoMessage

func (*GetSessionsResponse) ProtoMessage()

func (*GetSessionsResponse) ProtoReflect

func (x *GetSessionsResponse) ProtoReflect() protoreflect.Message

func (*GetSessionsResponse) Reset

func (x *GetSessionsResponse) Reset()

func (*GetSessionsResponse) String

func (x *GetSessionsResponse) String() string

type ListGatewayRequest

type ListGatewayRequest struct {
	Password string `protobuf:"bytes,1,opt,name=password,proto3" json:"password,omitempty"`
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// contains filtered or unexported fields
}

func (*ListGatewayRequest) Descriptor deprecated

func (*ListGatewayRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListGatewayRequest.ProtoReflect.Descriptor instead.

func (*ListGatewayRequest) GetPassword

func (x *ListGatewayRequest) GetPassword() string

func (*ListGatewayRequest) GetUsername

func (x *ListGatewayRequest) GetUsername() string

func (*ListGatewayRequest) ProtoMessage

func (*ListGatewayRequest) ProtoMessage()

func (*ListGatewayRequest) ProtoReflect

func (x *ListGatewayRequest) ProtoReflect() protoreflect.Message

func (*ListGatewayRequest) Reset

func (x *ListGatewayRequest) Reset()

func (*ListGatewayRequest) String

func (x *ListGatewayRequest) String() string

type LoginRequest

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

func (*LoginRequest) Descriptor deprecated

func (*LoginRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoginRequest.ProtoReflect.Descriptor instead.

func (*LoginRequest) ProtoMessage

func (*LoginRequest) ProtoMessage()

func (*LoginRequest) ProtoReflect

func (x *LoginRequest) ProtoReflect() protoreflect.Message

func (*LoginRequest) Reset

func (x *LoginRequest) Reset()

func (*LoginRequest) String

func (x *LoginRequest) String() string

type LoginResponse

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

func (*LoginResponse) Descriptor deprecated

func (*LoginResponse) Descriptor() ([]byte, []int)

Deprecated: Use LoginResponse.ProtoReflect.Descriptor instead.

func (*LoginResponse) ProtoMessage

func (*LoginResponse) ProtoMessage()

func (*LoginResponse) ProtoReflect

func (x *LoginResponse) ProtoReflect() protoreflect.Message

func (*LoginResponse) Reset

func (x *LoginResponse) Reset()

func (*LoginResponse) String

func (x *LoginResponse) String() string

type LogoutRequest

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

func (*LogoutRequest) Descriptor deprecated

func (*LogoutRequest) Descriptor() ([]byte, []int)

Deprecated: Use LogoutRequest.ProtoReflect.Descriptor instead.

func (*LogoutRequest) ProtoMessage

func (*LogoutRequest) ProtoMessage()

func (*LogoutRequest) ProtoReflect

func (x *LogoutRequest) ProtoReflect() protoreflect.Message

func (*LogoutRequest) Reset

func (x *LogoutRequest) Reset()

func (*LogoutRequest) String

func (x *LogoutRequest) String() string

type LogoutResponse

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

func (*LogoutResponse) Descriptor deprecated

func (*LogoutResponse) Descriptor() ([]byte, []int)

Deprecated: Use LogoutResponse.ProtoReflect.Descriptor instead.

func (*LogoutResponse) ProtoMessage

func (*LogoutResponse) ProtoMessage()

func (*LogoutResponse) ProtoReflect

func (x *LogoutResponse) ProtoReflect() protoreflect.Message

func (*LogoutResponse) Reset

func (x *LogoutResponse) Reset()

func (*LogoutResponse) String

func (x *LogoutResponse) String() string

type MockAPIServerClient

type MockAPIServerClient struct {
	mock.Mock
}

MockAPIServerClient is an autogenerated mock type for the APIServerClient type

func NewMockAPIServerClient

func NewMockAPIServerClient(t interface {
	mock.TestingT
	Cleanup(func())
},
) *MockAPIServerClient

NewMockAPIServerClient creates a new instance of MockAPIServerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockAPIServerClient) EXPECT

func (*MockAPIServerClient) EnrollGateway

EnrollGateway provides a mock function with given fields: ctx, in, opts

func (*MockAPIServerClient) GetDeviceConfiguration

GetDeviceConfiguration provides a mock function with given fields: ctx, in, opts

func (*MockAPIServerClient) GetGateway

func (_m *MockAPIServerClient) GetGateway(ctx context.Context, in *ModifyGatewayRequest, opts ...grpc.CallOption) (*Gateway, error)

GetGateway provides a mock function with given fields: ctx, in, opts

func (*MockAPIServerClient) GetGatewayConfiguration

GetGatewayConfiguration provides a mock function with given fields: ctx, in, opts

func (*MockAPIServerClient) GetSessions

GetSessions provides a mock function with given fields: ctx, in, opts

func (*MockAPIServerClient) ListGateways

ListGateways provides a mock function with given fields: ctx, in, opts

func (*MockAPIServerClient) Login

Login provides a mock function with given fields: ctx, in, opts

func (*MockAPIServerClient) UpdateGateway

UpdateGateway provides a mock function with given fields: ctx, in, opts

type MockAPIServerClient_EnrollGateway_Call

type MockAPIServerClient_EnrollGateway_Call struct {
	*mock.Call
}

MockAPIServerClient_EnrollGateway_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnrollGateway'

func (*MockAPIServerClient_EnrollGateway_Call) Return

func (*MockAPIServerClient_EnrollGateway_Call) Run

type MockAPIServerClient_Expecter

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

func (*MockAPIServerClient_Expecter) EnrollGateway

func (_e *MockAPIServerClient_Expecter) EnrollGateway(ctx interface{}, in interface{}, opts ...interface{}) *MockAPIServerClient_EnrollGateway_Call

EnrollGateway is a helper method to define mock.On call

  • ctx context.Context
  • in *ModifyGatewayRequest
  • opts ...grpc.CallOption

func (*MockAPIServerClient_Expecter) GetDeviceConfiguration

func (_e *MockAPIServerClient_Expecter) GetDeviceConfiguration(ctx interface{}, in interface{}, opts ...interface{}) *MockAPIServerClient_GetDeviceConfiguration_Call

GetDeviceConfiguration is a helper method to define mock.On call

  • ctx context.Context
  • in *GetDeviceConfigurationRequest
  • opts ...grpc.CallOption

func (*MockAPIServerClient_Expecter) GetGateway

func (_e *MockAPIServerClient_Expecter) GetGateway(ctx interface{}, in interface{}, opts ...interface{}) *MockAPIServerClient_GetGateway_Call

GetGateway is a helper method to define mock.On call

  • ctx context.Context
  • in *ModifyGatewayRequest
  • opts ...grpc.CallOption

func (*MockAPIServerClient_Expecter) GetGatewayConfiguration

func (_e *MockAPIServerClient_Expecter) GetGatewayConfiguration(ctx interface{}, in interface{}, opts ...interface{}) *MockAPIServerClient_GetGatewayConfiguration_Call

GetGatewayConfiguration is a helper method to define mock.On call

  • ctx context.Context
  • in *GetGatewayConfigurationRequest
  • opts ...grpc.CallOption

func (*MockAPIServerClient_Expecter) GetSessions

func (_e *MockAPIServerClient_Expecter) GetSessions(ctx interface{}, in interface{}, opts ...interface{}) *MockAPIServerClient_GetSessions_Call

GetSessions is a helper method to define mock.On call

  • ctx context.Context
  • in *GetSessionsRequest
  • opts ...grpc.CallOption

func (*MockAPIServerClient_Expecter) ListGateways

func (_e *MockAPIServerClient_Expecter) ListGateways(ctx interface{}, in interface{}, opts ...interface{}) *MockAPIServerClient_ListGateways_Call

ListGateways is a helper method to define mock.On call

  • ctx context.Context
  • in *ListGatewayRequest
  • opts ...grpc.CallOption

func (*MockAPIServerClient_Expecter) Login

func (_e *MockAPIServerClient_Expecter) Login(ctx interface{}, in interface{}, opts ...interface{}) *MockAPIServerClient_Login_Call

Login is a helper method to define mock.On call

  • ctx context.Context
  • in *APIServerLoginRequest
  • opts ...grpc.CallOption

func (*MockAPIServerClient_Expecter) UpdateGateway

func (_e *MockAPIServerClient_Expecter) UpdateGateway(ctx interface{}, in interface{}, opts ...interface{}) *MockAPIServerClient_UpdateGateway_Call

UpdateGateway is a helper method to define mock.On call

  • ctx context.Context
  • in *ModifyGatewayRequest
  • opts ...grpc.CallOption

type MockAPIServerClient_GetDeviceConfiguration_Call

type MockAPIServerClient_GetDeviceConfiguration_Call struct {
	*mock.Call
}

MockAPIServerClient_GetDeviceConfiguration_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDeviceConfiguration'

func (*MockAPIServerClient_GetDeviceConfiguration_Call) Run

type MockAPIServerClient_GetGatewayConfiguration_Call

type MockAPIServerClient_GetGatewayConfiguration_Call struct {
	*mock.Call
}

MockAPIServerClient_GetGatewayConfiguration_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetGatewayConfiguration'

func (*MockAPIServerClient_GetGatewayConfiguration_Call) Run

type MockAPIServerClient_GetGateway_Call

type MockAPIServerClient_GetGateway_Call struct {
	*mock.Call
}

MockAPIServerClient_GetGateway_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetGateway'

func (*MockAPIServerClient_GetGateway_Call) Return

func (*MockAPIServerClient_GetGateway_Call) Run

func (*MockAPIServerClient_GetGateway_Call) RunAndReturn

type MockAPIServerClient_GetSessions_Call

type MockAPIServerClient_GetSessions_Call struct {
	*mock.Call
}

MockAPIServerClient_GetSessions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSessions'

func (*MockAPIServerClient_GetSessions_Call) Return

func (*MockAPIServerClient_GetSessions_Call) Run

type MockAPIServerClient_ListGateways_Call

type MockAPIServerClient_ListGateways_Call struct {
	*mock.Call
}

MockAPIServerClient_ListGateways_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListGateways'

func (*MockAPIServerClient_ListGateways_Call) Return

func (*MockAPIServerClient_ListGateways_Call) Run

type MockAPIServerClient_Login_Call

type MockAPIServerClient_Login_Call struct {
	*mock.Call
}

MockAPIServerClient_Login_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Login'

func (*MockAPIServerClient_Login_Call) Return

func (*MockAPIServerClient_Login_Call) Run

type MockAPIServerClient_UpdateGateway_Call

type MockAPIServerClient_UpdateGateway_Call struct {
	*mock.Call
}

MockAPIServerClient_UpdateGateway_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateGateway'

func (*MockAPIServerClient_UpdateGateway_Call) Return

func (*MockAPIServerClient_UpdateGateway_Call) Run

type MockAPIServer_GetDeviceConfigurationClient

type MockAPIServer_GetDeviceConfigurationClient struct {
	mock.Mock
}

MockAPIServer_GetDeviceConfigurationClient is an autogenerated mock type for the APIServer_GetDeviceConfigurationClient type

func NewMockAPIServer_GetDeviceConfigurationClient

func NewMockAPIServer_GetDeviceConfigurationClient(t interface {
	mock.TestingT
	Cleanup(func())
},
) *MockAPIServer_GetDeviceConfigurationClient

NewMockAPIServer_GetDeviceConfigurationClient creates a new instance of MockAPIServer_GetDeviceConfigurationClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockAPIServer_GetDeviceConfigurationClient) CloseSend

CloseSend provides a mock function with given fields:

func (*MockAPIServer_GetDeviceConfigurationClient) Context

Context provides a mock function with given fields:

func (*MockAPIServer_GetDeviceConfigurationClient) EXPECT

func (*MockAPIServer_GetDeviceConfigurationClient) Header

Header provides a mock function with given fields:

func (*MockAPIServer_GetDeviceConfigurationClient) Recv

Recv provides a mock function with given fields:

func (*MockAPIServer_GetDeviceConfigurationClient) RecvMsg

func (_m *MockAPIServer_GetDeviceConfigurationClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockAPIServer_GetDeviceConfigurationClient) SendMsg

func (_m *MockAPIServer_GetDeviceConfigurationClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*MockAPIServer_GetDeviceConfigurationClient) Trailer

Trailer provides a mock function with given fields:

type MockAPIServer_GetDeviceConfigurationClient_CloseSend_Call

type MockAPIServer_GetDeviceConfigurationClient_CloseSend_Call struct {
	*mock.Call
}

MockAPIServer_GetDeviceConfigurationClient_CloseSend_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CloseSend'

func (*MockAPIServer_GetDeviceConfigurationClient_CloseSend_Call) Return

func (*MockAPIServer_GetDeviceConfigurationClient_CloseSend_Call) Run

func (*MockAPIServer_GetDeviceConfigurationClient_CloseSend_Call) RunAndReturn

type MockAPIServer_GetDeviceConfigurationClient_Context_Call

type MockAPIServer_GetDeviceConfigurationClient_Context_Call struct {
	*mock.Call
}

MockAPIServer_GetDeviceConfigurationClient_Context_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Context'

func (*MockAPIServer_GetDeviceConfigurationClient_Context_Call) Return

func (*MockAPIServer_GetDeviceConfigurationClient_Context_Call) Run

func (*MockAPIServer_GetDeviceConfigurationClient_Context_Call) RunAndReturn

type MockAPIServer_GetDeviceConfigurationClient_Expecter

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

func (*MockAPIServer_GetDeviceConfigurationClient_Expecter) CloseSend

CloseSend is a helper method to define mock.On call

func (*MockAPIServer_GetDeviceConfigurationClient_Expecter) Context

Context is a helper method to define mock.On call

func (*MockAPIServer_GetDeviceConfigurationClient_Expecter) Header

Header is a helper method to define mock.On call

func (*MockAPIServer_GetDeviceConfigurationClient_Expecter) Recv

Recv is a helper method to define mock.On call

func (*MockAPIServer_GetDeviceConfigurationClient_Expecter) RecvMsg

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockAPIServer_GetDeviceConfigurationClient_Expecter) SendMsg

SendMsg is a helper method to define mock.On call

  • m interface{}

func (*MockAPIServer_GetDeviceConfigurationClient_Expecter) Trailer

Trailer is a helper method to define mock.On call

type MockAPIServer_GetDeviceConfigurationClient_Header_Call

type MockAPIServer_GetDeviceConfigurationClient_Header_Call struct {
	*mock.Call
}

MockAPIServer_GetDeviceConfigurationClient_Header_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Header'

func (*MockAPIServer_GetDeviceConfigurationClient_Header_Call) Return

func (*MockAPIServer_GetDeviceConfigurationClient_Header_Call) Run

func (*MockAPIServer_GetDeviceConfigurationClient_Header_Call) RunAndReturn

type MockAPIServer_GetDeviceConfigurationClient_RecvMsg_Call

type MockAPIServer_GetDeviceConfigurationClient_RecvMsg_Call struct {
	*mock.Call
}

MockAPIServer_GetDeviceConfigurationClient_RecvMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecvMsg'

func (*MockAPIServer_GetDeviceConfigurationClient_RecvMsg_Call) Return

func (*MockAPIServer_GetDeviceConfigurationClient_RecvMsg_Call) Run

func (*MockAPIServer_GetDeviceConfigurationClient_RecvMsg_Call) RunAndReturn

type MockAPIServer_GetDeviceConfigurationClient_Recv_Call

type MockAPIServer_GetDeviceConfigurationClient_Recv_Call struct {
	*mock.Call
}

MockAPIServer_GetDeviceConfigurationClient_Recv_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Recv'

func (*MockAPIServer_GetDeviceConfigurationClient_Recv_Call) Return

func (*MockAPIServer_GetDeviceConfigurationClient_Recv_Call) Run

func (*MockAPIServer_GetDeviceConfigurationClient_Recv_Call) RunAndReturn

type MockAPIServer_GetDeviceConfigurationClient_SendMsg_Call

type MockAPIServer_GetDeviceConfigurationClient_SendMsg_Call struct {
	*mock.Call
}

MockAPIServer_GetDeviceConfigurationClient_SendMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendMsg'

func (*MockAPIServer_GetDeviceConfigurationClient_SendMsg_Call) Return

func (*MockAPIServer_GetDeviceConfigurationClient_SendMsg_Call) Run

func (*MockAPIServer_GetDeviceConfigurationClient_SendMsg_Call) RunAndReturn

type MockAPIServer_GetDeviceConfigurationClient_Trailer_Call

type MockAPIServer_GetDeviceConfigurationClient_Trailer_Call struct {
	*mock.Call
}

MockAPIServer_GetDeviceConfigurationClient_Trailer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Trailer'

func (*MockAPIServer_GetDeviceConfigurationClient_Trailer_Call) Return

func (*MockAPIServer_GetDeviceConfigurationClient_Trailer_Call) Run

func (*MockAPIServer_GetDeviceConfigurationClient_Trailer_Call) RunAndReturn

type MockAPIServer_GetGatewayConfigurationClient

type MockAPIServer_GetGatewayConfigurationClient struct {
	mock.Mock
}

MockAPIServer_GetGatewayConfigurationClient is an autogenerated mock type for the APIServer_GetGatewayConfigurationClient type

func NewMockAPIServer_GetGatewayConfigurationClient

func NewMockAPIServer_GetGatewayConfigurationClient(t interface {
	mock.TestingT
	Cleanup(func())
},
) *MockAPIServer_GetGatewayConfigurationClient

NewMockAPIServer_GetGatewayConfigurationClient creates a new instance of MockAPIServer_GetGatewayConfigurationClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockAPIServer_GetGatewayConfigurationClient) CloseSend

CloseSend provides a mock function with given fields:

func (*MockAPIServer_GetGatewayConfigurationClient) Context

Context provides a mock function with given fields:

func (*MockAPIServer_GetGatewayConfigurationClient) EXPECT

func (*MockAPIServer_GetGatewayConfigurationClient) Header

Header provides a mock function with given fields:

func (*MockAPIServer_GetGatewayConfigurationClient) Recv

Recv provides a mock function with given fields:

func (*MockAPIServer_GetGatewayConfigurationClient) RecvMsg

func (_m *MockAPIServer_GetGatewayConfigurationClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockAPIServer_GetGatewayConfigurationClient) SendMsg

func (_m *MockAPIServer_GetGatewayConfigurationClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*MockAPIServer_GetGatewayConfigurationClient) Trailer

Trailer provides a mock function with given fields:

type MockAPIServer_GetGatewayConfigurationClient_CloseSend_Call

type MockAPIServer_GetGatewayConfigurationClient_CloseSend_Call struct {
	*mock.Call
}

MockAPIServer_GetGatewayConfigurationClient_CloseSend_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CloseSend'

func (*MockAPIServer_GetGatewayConfigurationClient_CloseSend_Call) Return

func (*MockAPIServer_GetGatewayConfigurationClient_CloseSend_Call) Run

func (*MockAPIServer_GetGatewayConfigurationClient_CloseSend_Call) RunAndReturn

type MockAPIServer_GetGatewayConfigurationClient_Context_Call

type MockAPIServer_GetGatewayConfigurationClient_Context_Call struct {
	*mock.Call
}

MockAPIServer_GetGatewayConfigurationClient_Context_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Context'

func (*MockAPIServer_GetGatewayConfigurationClient_Context_Call) Return

func (*MockAPIServer_GetGatewayConfigurationClient_Context_Call) Run

func (*MockAPIServer_GetGatewayConfigurationClient_Context_Call) RunAndReturn

type MockAPIServer_GetGatewayConfigurationClient_Expecter

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

func (*MockAPIServer_GetGatewayConfigurationClient_Expecter) CloseSend

CloseSend is a helper method to define mock.On call

func (*MockAPIServer_GetGatewayConfigurationClient_Expecter) Context

Context is a helper method to define mock.On call

func (*MockAPIServer_GetGatewayConfigurationClient_Expecter) Header

Header is a helper method to define mock.On call

func (*MockAPIServer_GetGatewayConfigurationClient_Expecter) Recv

Recv is a helper method to define mock.On call

func (*MockAPIServer_GetGatewayConfigurationClient_Expecter) RecvMsg

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockAPIServer_GetGatewayConfigurationClient_Expecter) SendMsg

SendMsg is a helper method to define mock.On call

  • m interface{}

func (*MockAPIServer_GetGatewayConfigurationClient_Expecter) Trailer

Trailer is a helper method to define mock.On call

type MockAPIServer_GetGatewayConfigurationClient_Header_Call

type MockAPIServer_GetGatewayConfigurationClient_Header_Call struct {
	*mock.Call
}

MockAPIServer_GetGatewayConfigurationClient_Header_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Header'

func (*MockAPIServer_GetGatewayConfigurationClient_Header_Call) Return

func (*MockAPIServer_GetGatewayConfigurationClient_Header_Call) Run

func (*MockAPIServer_GetGatewayConfigurationClient_Header_Call) RunAndReturn

type MockAPIServer_GetGatewayConfigurationClient_RecvMsg_Call

type MockAPIServer_GetGatewayConfigurationClient_RecvMsg_Call struct {
	*mock.Call
}

MockAPIServer_GetGatewayConfigurationClient_RecvMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecvMsg'

func (*MockAPIServer_GetGatewayConfigurationClient_RecvMsg_Call) Return

func (*MockAPIServer_GetGatewayConfigurationClient_RecvMsg_Call) Run

func (*MockAPIServer_GetGatewayConfigurationClient_RecvMsg_Call) RunAndReturn

type MockAPIServer_GetGatewayConfigurationClient_Recv_Call

type MockAPIServer_GetGatewayConfigurationClient_Recv_Call struct {
	*mock.Call
}

MockAPIServer_GetGatewayConfigurationClient_Recv_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Recv'

func (*MockAPIServer_GetGatewayConfigurationClient_Recv_Call) Run

func (*MockAPIServer_GetGatewayConfigurationClient_Recv_Call) RunAndReturn

type MockAPIServer_GetGatewayConfigurationClient_SendMsg_Call

type MockAPIServer_GetGatewayConfigurationClient_SendMsg_Call struct {
	*mock.Call
}

MockAPIServer_GetGatewayConfigurationClient_SendMsg_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendMsg'

func (*MockAPIServer_GetGatewayConfigurationClient_SendMsg_Call) Return

func (*MockAPIServer_GetGatewayConfigurationClient_SendMsg_Call) Run

func (*MockAPIServer_GetGatewayConfigurationClient_SendMsg_Call) RunAndReturn

type MockAPIServer_GetGatewayConfigurationClient_Trailer_Call

type MockAPIServer_GetGatewayConfigurationClient_Trailer_Call struct {
	*mock.Call
}

MockAPIServer_GetGatewayConfigurationClient_Trailer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Trailer'

func (*MockAPIServer_GetGatewayConfigurationClient_Trailer_Call) Return

func (*MockAPIServer_GetGatewayConfigurationClient_Trailer_Call) Run

func (*MockAPIServer_GetGatewayConfigurationClient_Trailer_Call) RunAndReturn

type MockDeviceHelperClient

type MockDeviceHelperClient struct {
	mock.Mock
}

MockDeviceHelperClient is an autogenerated mock type for the DeviceHelperClient type

func NewMockDeviceHelperClient

func NewMockDeviceHelperClient(t interface {
	mock.TestingT
	Cleanup(func())
},
) *MockDeviceHelperClient

NewMockDeviceHelperClient creates a new instance of MockDeviceHelperClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockDeviceHelperClient) Configure

Configure provides a mock function with given fields: ctx, in, opts

func (*MockDeviceHelperClient) EXPECT

func (*MockDeviceHelperClient) GetSerial

GetSerial provides a mock function with given fields: ctx, in, opts

func (*MockDeviceHelperClient) Teardown

Teardown provides a mock function with given fields: ctx, in, opts

func (*MockDeviceHelperClient) Upgrade

Upgrade provides a mock function with given fields: ctx, in, opts

type MockDeviceHelperClient_Configure_Call

type MockDeviceHelperClient_Configure_Call struct {
	*mock.Call
}

MockDeviceHelperClient_Configure_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Configure'

func (*MockDeviceHelperClient_Configure_Call) Return

func (*MockDeviceHelperClient_Configure_Call) Run

func (*MockDeviceHelperClient_Configure_Call) RunAndReturn

type MockDeviceHelperClient_Expecter

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

func (*MockDeviceHelperClient_Expecter) Configure

func (_e *MockDeviceHelperClient_Expecter) Configure(ctx interface{}, in interface{}, opts ...interface{}) *MockDeviceHelperClient_Configure_Call

Configure is a helper method to define mock.On call

  • ctx context.Context
  • in *Configuration
  • opts ...grpc.CallOption

func (*MockDeviceHelperClient_Expecter) GetSerial

func (_e *MockDeviceHelperClient_Expecter) GetSerial(ctx interface{}, in interface{}, opts ...interface{}) *MockDeviceHelperClient_GetSerial_Call

GetSerial is a helper method to define mock.On call

  • ctx context.Context
  • in *GetSerialRequest
  • opts ...grpc.CallOption

func (*MockDeviceHelperClient_Expecter) Teardown

func (_e *MockDeviceHelperClient_Expecter) Teardown(ctx interface{}, in interface{}, opts ...interface{}) *MockDeviceHelperClient_Teardown_Call

Teardown is a helper method to define mock.On call

  • ctx context.Context
  • in *TeardownRequest
  • opts ...grpc.CallOption

func (*MockDeviceHelperClient_Expecter) Upgrade

func (_e *MockDeviceHelperClient_Expecter) Upgrade(ctx interface{}, in interface{}, opts ...interface{}) *MockDeviceHelperClient_Upgrade_Call

Upgrade is a helper method to define mock.On call

  • ctx context.Context
  • in *UpgradeRequest
  • opts ...grpc.CallOption

type MockDeviceHelperClient_GetSerial_Call

type MockDeviceHelperClient_GetSerial_Call struct {
	*mock.Call
}

MockDeviceHelperClient_GetSerial_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSerial'

func (*MockDeviceHelperClient_GetSerial_Call) Return

func (*MockDeviceHelperClient_GetSerial_Call) Run

func (*MockDeviceHelperClient_GetSerial_Call) RunAndReturn

type MockDeviceHelperClient_Teardown_Call

type MockDeviceHelperClient_Teardown_Call struct {
	*mock.Call
}

MockDeviceHelperClient_Teardown_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Teardown'

func (*MockDeviceHelperClient_Teardown_Call) Return

func (*MockDeviceHelperClient_Teardown_Call) Run

func (*MockDeviceHelperClient_Teardown_Call) RunAndReturn

type MockDeviceHelperClient_Upgrade_Call

type MockDeviceHelperClient_Upgrade_Call struct {
	*mock.Call
}

MockDeviceHelperClient_Upgrade_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Upgrade'

func (*MockDeviceHelperClient_Upgrade_Call) Return

func (*MockDeviceHelperClient_Upgrade_Call) Run

func (*MockDeviceHelperClient_Upgrade_Call) RunAndReturn

type ModifyGatewayRequest

type ModifyGatewayRequest struct {
	Password string   `protobuf:"bytes,1,opt,name=password,proto3" json:"password,omitempty"` // authentication token
	Gateway  *Gateway `protobuf:"bytes,2,opt,name=gateway,proto3" json:"gateway,omitempty"`
	Username string   `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyGatewayRequest) Descriptor deprecated

func (*ModifyGatewayRequest) Descriptor() ([]byte, []int)

Deprecated: Use ModifyGatewayRequest.ProtoReflect.Descriptor instead.

func (*ModifyGatewayRequest) GetGateway

func (x *ModifyGatewayRequest) GetGateway() *Gateway

func (*ModifyGatewayRequest) GetPassword

func (x *ModifyGatewayRequest) GetPassword() string

func (*ModifyGatewayRequest) GetUsername

func (x *ModifyGatewayRequest) GetUsername() string

func (*ModifyGatewayRequest) ProtoMessage

func (*ModifyGatewayRequest) ProtoMessage()

func (*ModifyGatewayRequest) ProtoReflect

func (x *ModifyGatewayRequest) ProtoReflect() protoreflect.Message

func (*ModifyGatewayRequest) Reset

func (x *ModifyGatewayRequest) Reset()

func (*ModifyGatewayRequest) String

func (x *ModifyGatewayRequest) String() string

type ModifyGatewayResponse

type ModifyGatewayResponse struct {
	Gateway *Gateway `protobuf:"bytes,1,opt,name=gateway,proto3" json:"gateway,omitempty"`
	// contains filtered or unexported fields
}

func (*ModifyGatewayResponse) Descriptor deprecated

func (*ModifyGatewayResponse) Descriptor() ([]byte, []int)

Deprecated: Use ModifyGatewayResponse.ProtoReflect.Descriptor instead.

func (*ModifyGatewayResponse) GetGateway

func (x *ModifyGatewayResponse) GetGateway() *Gateway

func (*ModifyGatewayResponse) ProtoMessage

func (*ModifyGatewayResponse) ProtoMessage()

func (*ModifyGatewayResponse) ProtoReflect

func (x *ModifyGatewayResponse) ProtoReflect() protoreflect.Message

func (*ModifyGatewayResponse) Reset

func (x *ModifyGatewayResponse) Reset()

func (*ModifyGatewayResponse) String

func (x *ModifyGatewayResponse) String() string

type Session

type Session struct {
	Key      string                 `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Expiry   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expiry,proto3" json:"expiry,omitempty"`
	Device   *Device                `protobuf:"bytes,3,opt,name=device,proto3" json:"device,omitempty"`
	Groups   []string               `protobuf:"bytes,4,rep,name=groups,proto3" json:"groups,omitempty"`
	ObjectID string                 `protobuf:"bytes,5,opt,name=objectID,proto3" json:"objectID,omitempty"`
	// contains filtered or unexported fields
}

func (*Session) Descriptor deprecated

func (*Session) Descriptor() ([]byte, []int)

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) Expired

func (x *Session) Expired() bool

func (*Session) GetDevice

func (x *Session) GetDevice() *Device

func (*Session) GetExpiry

func (x *Session) GetExpiry() *timestamppb.Timestamp

func (*Session) GetGroups

func (x *Session) GetGroups() []string

func (*Session) GetKey

func (x *Session) GetKey() string

func (*Session) GetObjectID

func (x *Session) GetObjectID() string

func (*Session) ProtoMessage

func (*Session) ProtoMessage()

func (*Session) ProtoReflect

func (x *Session) ProtoReflect() protoreflect.Message

func (*Session) Reset

func (x *Session) Reset()

func (*Session) String

func (x *Session) String() string

type SetActiveTenantRequest

type SetActiveTenantRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*SetActiveTenantRequest) Descriptor deprecated

func (*SetActiveTenantRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetActiveTenantRequest.ProtoReflect.Descriptor instead.

func (*SetActiveTenantRequest) GetName

func (x *SetActiveTenantRequest) GetName() string

func (*SetActiveTenantRequest) ProtoMessage

func (*SetActiveTenantRequest) ProtoMessage()

func (*SetActiveTenantRequest) ProtoReflect

func (x *SetActiveTenantRequest) ProtoReflect() protoreflect.Message

func (*SetActiveTenantRequest) Reset

func (x *SetActiveTenantRequest) Reset()

func (*SetActiveTenantRequest) String

func (x *SetActiveTenantRequest) String() string

type SetActiveTenantResponse

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

func (*SetActiveTenantResponse) Descriptor deprecated

func (*SetActiveTenantResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetActiveTenantResponse.ProtoReflect.Descriptor instead.

func (*SetActiveTenantResponse) ProtoMessage

func (*SetActiveTenantResponse) ProtoMessage()

func (*SetActiveTenantResponse) ProtoReflect

func (x *SetActiveTenantResponse) ProtoReflect() protoreflect.Message

func (*SetActiveTenantResponse) Reset

func (x *SetActiveTenantResponse) Reset()

func (*SetActiveTenantResponse) String

func (x *SetActiveTenantResponse) String() string

type SetAgentConfigurationRequest

type SetAgentConfigurationRequest struct {
	Config *AgentConfiguration `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*SetAgentConfigurationRequest) Descriptor deprecated

func (*SetAgentConfigurationRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetAgentConfigurationRequest.ProtoReflect.Descriptor instead.

func (*SetAgentConfigurationRequest) GetConfig

func (*SetAgentConfigurationRequest) ProtoMessage

func (*SetAgentConfigurationRequest) ProtoMessage()

func (*SetAgentConfigurationRequest) ProtoReflect

func (*SetAgentConfigurationRequest) Reset

func (x *SetAgentConfigurationRequest) Reset()

func (*SetAgentConfigurationRequest) String

type SetAgentConfigurationResponse

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

func (*SetAgentConfigurationResponse) Descriptor deprecated

func (*SetAgentConfigurationResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetAgentConfigurationResponse.ProtoReflect.Descriptor instead.

func (*SetAgentConfigurationResponse) ProtoMessage

func (*SetAgentConfigurationResponse) ProtoMessage()

func (*SetAgentConfigurationResponse) ProtoReflect

func (*SetAgentConfigurationResponse) Reset

func (x *SetAgentConfigurationResponse) Reset()

func (*SetAgentConfigurationResponse) String

type TeardownRequest

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

func (*TeardownRequest) Descriptor deprecated

func (*TeardownRequest) Descriptor() ([]byte, []int)

Deprecated: Use TeardownRequest.ProtoReflect.Descriptor instead.

func (*TeardownRequest) ProtoMessage

func (*TeardownRequest) ProtoMessage()

func (*TeardownRequest) ProtoReflect

func (x *TeardownRequest) ProtoReflect() protoreflect.Message

func (*TeardownRequest) Reset

func (x *TeardownRequest) Reset()

func (*TeardownRequest) String

func (x *TeardownRequest) String() string

type TeardownResponse

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

func (*TeardownResponse) Descriptor deprecated

func (*TeardownResponse) Descriptor() ([]byte, []int)

Deprecated: Use TeardownResponse.ProtoReflect.Descriptor instead.

func (*TeardownResponse) ProtoMessage

func (*TeardownResponse) ProtoMessage()

func (*TeardownResponse) ProtoReflect

func (x *TeardownResponse) ProtoReflect() protoreflect.Message

func (*TeardownResponse) Reset

func (x *TeardownResponse) Reset()

func (*TeardownResponse) String

func (x *TeardownResponse) String() string

type Tenant

type Tenant struct {
	Name         string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	AuthProvider AuthProvider `protobuf:"varint,2,opt,name=authProvider,proto3,enum=naisdevice.AuthProvider" json:"authProvider,omitempty"`
	Domain       string       `protobuf:"bytes,4,opt,name=domain,proto3" json:"domain,omitempty"`
	Active       bool         `protobuf:"varint,5,opt,name=active,proto3" json:"active,omitempty"`
	Session      *Session     `protobuf:"bytes,6,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*Tenant) Descriptor deprecated

func (*Tenant) Descriptor() ([]byte, []int)

Deprecated: Use Tenant.ProtoReflect.Descriptor instead.

func (*Tenant) GetActive

func (x *Tenant) GetActive() bool

func (*Tenant) GetAuthProvider

func (x *Tenant) GetAuthProvider() AuthProvider

func (*Tenant) GetDomain

func (x *Tenant) GetDomain() string

func (*Tenant) GetName

func (x *Tenant) GetName() string

func (*Tenant) GetSession

func (x *Tenant) GetSession() *Session

func (*Tenant) ProtoMessage

func (*Tenant) ProtoMessage()

func (*Tenant) ProtoReflect

func (x *Tenant) ProtoReflect() protoreflect.Message

func (*Tenant) Reset

func (x *Tenant) Reset()

func (*Tenant) String

func (x *Tenant) String() string

type UnimplementedAPIServerServer

type UnimplementedAPIServerServer struct {
}

UnimplementedAPIServerServer must be embedded to have forward compatible implementations.

func (UnimplementedAPIServerServer) EnrollGateway

func (UnimplementedAPIServerServer) GetGateway

func (UnimplementedAPIServerServer) GetSessions

func (UnimplementedAPIServerServer) ListGateways

func (UnimplementedAPIServerServer) Login

func (UnimplementedAPIServerServer) UpdateGateway

type UnimplementedDeviceAgentServer

type UnimplementedDeviceAgentServer struct {
}

UnimplementedDeviceAgentServer must be embedded to have forward compatible implementations.

func (UnimplementedDeviceAgentServer) ConfigureJITA

func (UnimplementedDeviceAgentServer) Login

func (UnimplementedDeviceAgentServer) Logout

func (UnimplementedDeviceAgentServer) SetActiveTenant

func (UnimplementedDeviceAgentServer) Status

type UnimplementedDeviceHelperServer

type UnimplementedDeviceHelperServer struct {
}

UnimplementedDeviceHelperServer must be embedded to have forward compatible implementations.

func (UnimplementedDeviceHelperServer) Configure

func (UnimplementedDeviceHelperServer) GetSerial

func (UnimplementedDeviceHelperServer) Teardown

func (UnimplementedDeviceHelperServer) Upgrade

type UnsafeAPIServerServer

type UnsafeAPIServerServer interface {
	// contains filtered or unexported methods
}

UnsafeAPIServerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to APIServerServer will result in compilation errors.

type UnsafeDeviceAgentServer

type UnsafeDeviceAgentServer interface {
	// contains filtered or unexported methods
}

UnsafeDeviceAgentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DeviceAgentServer will result in compilation errors.

type UnsafeDeviceHelperServer

type UnsafeDeviceHelperServer interface {
	// contains filtered or unexported methods
}

UnsafeDeviceHelperServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DeviceHelperServer will result in compilation errors.

type UpgradeRequest

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

func (*UpgradeRequest) Descriptor deprecated

func (*UpgradeRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpgradeRequest.ProtoReflect.Descriptor instead.

func (*UpgradeRequest) ProtoMessage

func (*UpgradeRequest) ProtoMessage()

func (*UpgradeRequest) ProtoReflect

func (x *UpgradeRequest) ProtoReflect() protoreflect.Message

func (*UpgradeRequest) Reset

func (x *UpgradeRequest) Reset()

func (*UpgradeRequest) String

func (x *UpgradeRequest) String() string

type UpgradeResponse

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

func (*UpgradeResponse) Descriptor deprecated

func (*UpgradeResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpgradeResponse.ProtoReflect.Descriptor instead.

func (*UpgradeResponse) ProtoMessage

func (*UpgradeResponse) ProtoMessage()

func (*UpgradeResponse) ProtoReflect

func (x *UpgradeResponse) ProtoReflect() protoreflect.Message

func (*UpgradeResponse) Reset

func (x *UpgradeResponse) Reset()

func (*UpgradeResponse) String

func (x *UpgradeResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL