mycscloud

Documentation

Index

• type AppAPI
  • func NewAppAPI(apiClient *graphql.Client) *AppAPI
  • func (a *AppAPI) AddApp(tgt *target.Target, spaceID string) error
  • func (a *AppAPI) DeleteApp(tgt *target.Target) ([]string, error)
• type CloudAPI
  • func NewCloudAPI(apiClient *graphql.Client) *CloudAPI
  • func (c *CloudAPI) UpdateProperties(config config.Config) error
• type DeviceAPI
  • func NewDeviceAPI(apiClient *graphql.Client) *DeviceAPI
  • func (d *DeviceAPI) AddDeviceUser(deviceID, userID string) (string, string, error)
  • func (d *DeviceAPI) RegisterDevice(...) (string, string, error)
  • func (d *DeviceAPI) RemoveDeviceUser(deviceID, userID string) (string, string, error)
  • func (d *DeviceAPI) SetDeviceWireguardConfig(userID, deviceID, spaceID, wgConfigName, wgConfig string, ...) error
  • func (d *DeviceAPI) UnRegisterDevice(deviceID string) ([]string, error)
  • func (d *DeviceAPI) UpdateDeviceContext(deviceContext config.DeviceContext) error
• type EventPublisher
  • func NewEventPublisher(apiUrl, subUrl string, config config.Config) *EventPublisher
  • func (p *EventPublisher) PostMeasurementEvents(cloudEvents []*cloudevents.Event) ([]events.CloudEventError, error)
• type SpaceAPI
  • func NewSpaceAPI(apiClient *graphql.Client) *SpaceAPI
  • func (s *SpaceAPI) AddSpace(tgt *target.Target, isEgressNode bool) error
  • func (s *SpaceAPI) DeleteSpace(tgt *target.Target) ([]string, error)
  • func (s *SpaceAPI) GetSpaces() ([]*userspace.Space, error)
• type SpaceNodes
  • func GetSpaceNodes(config config.Config, apiUrl string) (*SpaceNodes, error)
  • func NewSpaceNodes(config config.Config) *SpaceNodes
  • func (sn *SpaceNodes) GetAllSpaces() []userspace.SpaceNode
  • func (sn *SpaceNodes) GetApiClientForSpace(space userspace.SpaceNode) (*mycsnode.ApiClient, error)
  • func (sn *SpaceNodes) GetSharedSpaces() []*userspace.Space
  • func (sn *SpaceNodes) LookupSpace(key string) userspace.SpaceNode
  • func (sn *SpaceNodes) LookupSpaceByEndpoint(endpoint string) userspace.SpaceNode
  • func (sn *SpaceNodes) ReleaseApiClientForSpace(apiClient *mycsnode.ApiClient)
• type UserAPI
  • func NewUserAPI(apiClient *graphql.Client) *UserAPI
  • func (u *UserAPI) GetUser(user *userspace.User) (*userspace.User, error)
  • func (u *UserAPI) GetUserConfig(user *userspace.User) ([]byte, error)
  • func (u *UserAPI) UpdateUserConfig(user *userspace.User, config []byte, asOfTimestamp int64) (int64, error)
  • func (u *UserAPI) UpdateUserKey(user *userspace.User) error
  • func (u *UserAPI) UserSearch(name string) ([]*userspace.User, error)

Types

type AppAPI

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

func NewAppAPI

func NewAppAPI(apiClient *graphql.Client) *AppAPI

func (*AppAPI) AddApp

func (a *AppAPI) AddApp(
	tgt *target.Target,
	spaceID string,
) error

func (*AppAPI) DeleteApp

func (a *AppAPI) DeleteApp(tgt *target.Target) ([]string, error)

type CloudAPI

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

func NewCloudAPI

func NewCloudAPI(apiClient *graphql.Client) *CloudAPI

func (*CloudAPI) UpdateProperties

func (c *CloudAPI) UpdateProperties(
	config config.Config,
) error

type DeviceAPI

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

func NewDeviceAPI

func NewDeviceAPI(apiClient *graphql.Client) *DeviceAPI

func (*DeviceAPI) AddDeviceUser

func (d *DeviceAPI) AddDeviceUser(deviceID, userID string) (string, string, error)

func (*DeviceAPI) RegisterDevice

func (d *DeviceAPI) RegisterDevice(
	deviceName,
	deviceType,
	clientVersion,
	deviceCertRequest,
	devicePublicKey,
	managedBy string,
) (string, string, error)

func (*DeviceAPI) RemoveDeviceUser

func (d *DeviceAPI) RemoveDeviceUser(deviceID, userID string) (string, string, error)

func (*DeviceAPI) SetDeviceWireguardConfig

func (d *DeviceAPI) SetDeviceWireguardConfig(
	userID,
	deviceID,
	spaceID,
	wgConfigName,
	wgConfig string,
	wgExpirationTimeout,
	wgInactivityTimeout int,
) error

func (*DeviceAPI) UnRegisterDevice

func (d *DeviceAPI) UnRegisterDevice(deviceID string) ([]string, error)

func (*DeviceAPI) UpdateDeviceContext

func (d *DeviceAPI) UpdateDeviceContext(deviceContext config.DeviceContext) error

type EventPublisher

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

func NewEventPublisher

func NewEventPublisher(apiUrl, subUrl string, config config.Config) *EventPublisher

func (*EventPublisher) PostMeasurementEvents

func (p *EventPublisher) PostMeasurementEvents(cloudEvents []*cloudevents.Event) ([]events.CloudEventError, error)

type SpaceAPI

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

func NewSpaceAPI

func NewSpaceAPI(apiClient *graphql.Client) *SpaceAPI

func (*SpaceAPI) AddSpace

func (s *SpaceAPI) AddSpace(
	tgt *target.Target,
	isEgressNode bool,
) error

func (*SpaceAPI) DeleteSpace

func (s *SpaceAPI) DeleteSpace(tgt *target.Target) ([]string, error)

func (*SpaceAPI) GetSpaces

func (s *SpaceAPI) GetSpaces() ([]*userspace.Space, error)

type SpaceNodes

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

space nodes aggregates remote and local nodes and consolidates and duplicates

func GetSpaceNodes

func GetSpaceNodes(config config.Config, apiUrl string) (*SpaceNodes, error)

load all owned and shared spaces

func NewSpaceNodes

func NewSpaceNodes(config config.Config) *SpaceNodes

load only local owned targets

func (*SpaceNodes) GetAllSpaces

func (sn *SpaceNodes) GetAllSpaces() []userspace.SpaceNode

func (*SpaceNodes) GetApiClientForSpace

func (sn *SpaceNodes) GetApiClientForSpace(space userspace.SpaceNode) (*mycsnode.ApiClient, error)

func (*SpaceNodes) GetSharedSpaces

func (sn *SpaceNodes) GetSharedSpaces() []*userspace.Space

func (*SpaceNodes) LookupSpace

func (sn *SpaceNodes) LookupSpace(key string) userspace.SpaceNode

func (*SpaceNodes) LookupSpaceByEndpoint

func (sn *SpaceNodes) LookupSpaceByEndpoint(endpoint string) userspace.SpaceNode

func (*SpaceNodes) ReleaseApiClientForSpace

func (sn *SpaceNodes) ReleaseApiClientForSpace(apiClient *mycsnode.ApiClient)

type UserAPI

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

func NewUserAPI

func NewUserAPI(apiClient *graphql.Client) *UserAPI

func (*UserAPI) GetUser

func (u *UserAPI) GetUser(user *userspace.User) (*userspace.User, error)

func (*UserAPI) GetUserConfig

func (u *UserAPI) GetUserConfig(user *userspace.User) ([]byte, error)

func (*UserAPI) UpdateUserConfig

func (u *UserAPI) UpdateUserConfig(user *userspace.User, config []byte, asOfTimestamp int64) (int64, error)

func (*UserAPI) UpdateUserKey

func (u *UserAPI) UpdateUserKey(user *userspace.User) error

func (*UserAPI) UserSearch

func (u *UserAPI) UserSearch(name string) ([]*userspace.User, error)