utils

Documentation

Index

• Constants
• Variables
• func AppendStrings(strings ...string) string
• func CreateUuid() string
• func IsUrl(checkUrl string) error
• func IsValidId(id string) bool
• func Join(stringSlice []string, delimiter string, enclosure string) string
• func MakePrepareForInExpression(target interface{}) (string, map[string]interface{})
• func MergeMap(baseMap map[string]interface{}, mergeMaps ...map[string]interface{}) map[string]interface{}
• func RemoveDuplicate(args []string) []string
• func SearchStringValueInSlice(slice []string, value string) bool
• type Config
• type Datastore
• type Dispatcher
  • func NewDispatcher(max int) *Dispatcher
  • func (d *Dispatcher) Wait()
  • func (d *Dispatcher) Work(ctx context.Context, proc WorkFunc)
• type JSONText
  • func (j JSONText) MarshalJSON() ([]byte, error)
  • func (j *JSONText) Scan(src interface{}) error
  • func (j JSONText) String() string
  • func (j *JSONText) Unmarshal(v interface{}) error
  • func (j *JSONText) UnmarshalJSON(data []byte) error
  • func (j JSONText) Value() (driver.Value, error)
• type Logging
• type Messaging
• type Notification
• type RealtimeServer
• type Storage
• type WorkFunc

Constants

const (
	APP_NAME      = "swagchat-api"
	API_VERSION   = "v0"
	BUILD_VERSION = "v0.4.0"
)

Variables

var (
	Cfg           *Config
	IsShowVersion bool
)

var AppLogger *zap.Logger

Functions

func AppendStrings

func AppendStrings(strings ...string) string

func CreateUuid

func CreateUuid() string

func IsUrl

func IsUrl(checkUrl string) error

func IsValidId

func IsValidId(id string) bool

func Join

func Join(stringSlice []string, delimiter string, enclosure string) string

func MakePrepareForInExpression

func MakePrepareForInExpression(target interface{}) (string, map[string]interface{})

func MergeMap

func MergeMap(baseMap map[string]interface{}, mergeMaps ...map[string]interface{}) map[string]interface{}

func RemoveDuplicate

func RemoveDuplicate(args []string) []string

func SearchStringValueInSlice

func SearchStringValueInSlice(slice []string, value string) bool

Types

type Config

type Config struct {
	Version        string
	Port           string
	Profiling      bool
	ErrorLogging   bool `yaml:"errorLogging"`
	Logging        *Logging
	Storage        *Storage
	Datastore      *Datastore
	Messaging      *Messaging
	Notification   *Notification
	RealtimeServer *RealtimeServer `yaml:"realtimeServer"`
}

type Datastore

type Datastore struct {
	Provider        string
	TableNamePrefix string `yaml:"tableNamePrefix"`

	// SQLite
	SqlitePath string `yaml:"sqlitePath"`

	// MySQL, GCP SQL
	User              string
	Password          string
	Database          string
	MasterHost        string `yaml:"masterHost"`
	MasterPort        string `yaml:"masterPort"`
	MaxIdleConnection string `yaml:"maxIdleConnection"`
	MaxOpenConnection string `yaml:"maxOpenConnection"`
	UseSSL            string `yaml:"useSSL"`     // "on" or "off"
	ServerName        string `yaml:"serverName"` // For GcpSQL, set SqlInstanceId.
	ServerCaPath      string `yaml:"serverCaPath"`
	ClientCertPath    string `yaml:"clientCertPath"`
	ClientKeyPath     string `yaml:"clientKeyPath"`

	// GCP SQL
	GcpProjectId string `yaml:"gcpProjectId"`
}

type Dispatcher

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

func NewDispatcher

func NewDispatcher(max int) *Dispatcher

func (*Dispatcher) Wait

func (d *Dispatcher) Wait()

func (*Dispatcher) Work

func (d *Dispatcher) Work(ctx context.Context, proc WorkFunc)

type JSONText

type JSONText json.RawMessage

func (JSONText) MarshalJSON

func (j JSONText) MarshalJSON() ([]byte, error)

MarshalJSON returns j as the JSON encoding of j.

func (*JSONText) Scan

func (j *JSONText) Scan(src interface{}) error

Scan stores the src in *j. No validation is done.

func (JSONText) String

func (j JSONText) String() string

Pretty printing for JSONText types

func (*JSONText) Unmarshal

func (j *JSONText) Unmarshal(v interface{}) error

Unmarshal unmarshal's the json in j to v, as in json.Unmarshal.

func (*JSONText) UnmarshalJSON

func (j *JSONText) UnmarshalJSON(data []byte) error

UnmarshalJSON sets *j to a copy of data

func (JSONText) Value

func (j JSONText) Value() (driver.Value, error)

Value returns j as a value. This does a validating unmarshal into another RawMessage. If j is invalid json, it returns an error.

type Logging

type Logging struct {
	Level string
}

type Messaging

type Messaging struct {
	Provider       string
	ThumbnailTopic string `yaml:"thumbnailTopic"`

	// GCP Pubsub
	GcpProjectId string `yaml:"gcpProjectId"`
	GcpJwtPath   string `yaml:"gcpJwtPath"`
}

type Notification

type Notification struct {
	Provider            string
	RoomTopicNamePrefix string `yaml:"roomTopicNamePrefix"`

	// AWS SNS
	AwsRegion                string `yaml:"awsRegion"`
	AwsAccessKeyId           string `yaml:"awsAccessKeyId"`
	AwsSecretAccessKey       string `yaml:"awsSecretAccessKey"`
	AwsApplicationArnIos     string `yaml:"awsApplicationArnIos"`
	AwsApplicationArnAndroid string `yaml:"awsApplicationArnAndroid"`
}

type RealtimeServer

type RealtimeServer struct {
	Endpoint string
}

type Storage

type Storage struct {
	Provider           string
	UploadBucket       string `yaml:"uploadBucket"`
	UploadDirectory    string `yaml:"uploadDirectory"`
	ThumbnailBucket    string `yaml:"thumbnailBucket"`
	ThumbnailDirectory string `yaml:"thumbnailDirectory"`

	// Local
	BaseUrl   string `yaml:"baseUrl"`
	LocalPath string `yaml:"localPath"`

	// GCP Storage
	GcpProjectId string `yaml:"gcpProjectId"`
	GcpJwtPath   string `yaml:"gcpJwtPath"`

	// AWS S3
	AwsRegion          string `yaml:"awsRegion"`
	AwsAccessKeyId     string `yaml:"awsAccessKeyId"`
	AwsSecretAccessKey string `yaml:"AwsSecretAccessKey"`
}

type WorkFunc

type WorkFunc func(context.Context)