util

Documentation

Index

• Constants
• Variables
• func CreateRedisClient(host string, port int, clientName string, useTLS bool) (rueidis.Client, error)
• func CreateSubscription(ctx context.Context, client *pubsub.Client, subscriptionName string, ...) (*pubsub.Subscription, error)
• func CreateTopic(ctx context.Context, client *pubsub.Client, topicName string, ...) (*pubsub.Topic, error)
• func GetADCProject(ctx context.Context) (string, error)
• func GetDefaultProjectID(ctx context.Context) (string, error)
• func GetGoogleCloudCLIProject(ctx context.Context) (string, error)
• func GraphErrorPresenter(ctx context.Context, e error) *gqlerror.Error
• func GraphPanicRecoverer(_ context.Context, p interface{}) error
• func NewNeo4jDriver(host string, port int, tls bool) (neo4j.DriverWithContext, error)
• func RandomHash(n int) string
• type DescopeLogger
  • func (l *DescopeLogger) Print(v ...interface{})
• type Neo4jZerologBoltLogger
  • func (nl *Neo4jZerologBoltLogger) LogClientMessage(id, msg string, args ...interface{})
  • func (nl *Neo4jZerologBoltLogger) LogServerMessage(id, msg string, args ...interface{})
• type ReaderCloser
  • func (rc *ReaderCloser) Close() error
  • func (rc *ReaderCloser) Read(p []byte) (int, error)

Constants

const (
	UserFacingTagKey = "userFacing"
)

Variables

var (
	UserFacingTag       = errors.Tag("userFacing")
	ErrBadRequest       = errors.New("Bad request", errors.Meta("code", 400))
	ErrPermissionDenied = errors.New("Permission denied", errors.Meta("code", 401))
)

Functions

func CreateRedisClient

func CreateRedisClient(host string, port int, clientName string, useTLS bool) (rueidis.Client, error)

func CreateSubscription

func CreateSubscription(ctx context.Context, client *pubsub.Client, subscriptionName string, subOpts pubsub.SubscriptionConfig) (*pubsub.Subscription, error)

func CreateTopic

func CreateTopic(ctx context.Context, client *pubsub.Client, topicName string, topicConfig *pubsub.TopicConfig) (*pubsub.Topic, error)

func GetADCProject

func GetADCProject(ctx context.Context) (string, error)

func GetDefaultProjectID

func GetDefaultProjectID(ctx context.Context) (string, error)

func GetGoogleCloudCLIProject

func GetGoogleCloudCLIProject(ctx context.Context) (string, error)

func GraphErrorPresenter

func GraphErrorPresenter(ctx context.Context, e error) *gqlerror.Error

func GraphPanicRecoverer

func GraphPanicRecoverer(_ context.Context, p interface{}) error

func NewNeo4jDriver

func NewNeo4jDriver(host string, port int, tls bool) (neo4j.DriverWithContext, error)

func RandomHash

func RandomHash(n int) string

Types

type DescopeLogger

type DescopeLogger struct {
	LogLevel logger.LogLevel
	Logger   *zerolog.Logger
}

func (*DescopeLogger) Print

func (l *DescopeLogger) Print(v ...interface{})

type Neo4jZerologBoltLogger

type Neo4jZerologBoltLogger struct {
	Logger *zerolog.Logger
}

func (*Neo4jZerologBoltLogger) LogClientMessage

func (nl *Neo4jZerologBoltLogger) LogClientMessage(id, msg string, args ...interface{})

func (*Neo4jZerologBoltLogger) LogServerMessage

func (nl *Neo4jZerologBoltLogger) LogServerMessage(id, msg string, args ...interface{})

type ReaderCloser

type ReaderCloser struct {
	Reader io.Reader
}

func (*ReaderCloser) Close

func (rc *ReaderCloser) Close() error

func (*ReaderCloser) Read

func (rc *ReaderCloser) Read(p []byte) (int, error)