infrastructure

Documentation

Index

• func LoadEnvString(key string, defaultValue *string) *string
• func LoadEnvToStruct(prefix string, dest interface{}) error
• func LoadGBPConfigEnv() (gbpapi.GBPConfig, error)
• func LoadGCPOAuth2ConfigEnv() (oauth2.OAuth2Config, error)
• func LoadGCPPubsubConfigEnv() (*gcpPubsubConfig, error)
• func NewGBPConfigEnv(clientID string, secret string, refreshToken string) gbpapi.GBPConfig
• func NewGBPNotification(ctx context.Context, config gbpapi.GBPConfig) (*gbpNotification, error)
• func NewGCPOAuth2ConfigEnv(clientID string, secret string, refreshToken string, redirectURL string) oauth2.OAuth2Config
• func NewGCPPubsubConfigEnv(clientID string, secret string, refreshToken string, topic string, ...) gcpPubsubConfig
• func NewGCPPubsubPublisher(service *gcpPubsubService) *gcpPubsubPublisher
• func NewGCPPubsubService(ctx context.Context, config gcppubsub.GCPPubsubConfig) (*gcpPubsubService, error)
• func NewGCPPubsubSubscriber(service *gcpPubsubService) *gcpPubsubSubscriber

Functions

func LoadEnvString

func LoadEnvString(key string, defaultValue *string) *string

* Load environment variables and convert to struct *

func LoadEnvToStruct

func LoadEnvToStruct(prefix string, dest interface{}) error

* Load environment variables and convert to struct *

func LoadGBPConfigEnv

func LoadGBPConfigEnv() (gbpapi.GBPConfig, error)

func LoadGCPOAuth2ConfigEnv

func LoadGCPOAuth2ConfigEnv() (oauth2.OAuth2Config, error)

func LoadGCPPubsubConfigEnv

func LoadGCPPubsubConfigEnv() (*gcpPubsubConfig, error)

func NewGBPConfigEnv

func NewGBPConfigEnv(clientID string, secret string, refreshToken string) gbpapi.GBPConfig

func NewGBPNotification

func NewGBPNotification(ctx context.Context, config gbpapi.GBPConfig) (*gbpNotification, error)

func NewGCPOAuth2ConfigEnv

func NewGCPOAuth2ConfigEnv(clientID string, secret string, refreshToken string, redirectURL string) oauth2.OAuth2Config

func NewGCPPubsubConfigEnv

func NewGCPPubsubConfigEnv(
	clientID string,
	secret string,
	refreshToken string,
	topic string,
	subscription string,
) gcpPubsubConfig

func NewGCPPubsubPublisher

func NewGCPPubsubPublisher(service *gcpPubsubService) *gcpPubsubPublisher

* GCP Pub/Sub Publisher *

func NewGCPPubsubService

func NewGCPPubsubService(ctx context.Context, config gcppubsub.GCPPubsubConfig) (*gcpPubsubService, error)

* GCP Pub/Sub Service *

func NewGCPPubsubSubscriber

func NewGCPPubsubSubscriber(service *gcpPubsubService) *gcpPubsubSubscriber

* GCP Pub/Sub Subscriber *