nbalake

README

nbalake

nbalake is a library for storing structured and unstructured nba data to either S3, minio, or other blob store.

Documentation

Index

• Constants
• func BucketName(y string, id string) string
• func ConnectionNew()
• func Exists(b string, k string) bool
• func Get(b string, f string) []byte
• func GetLatestLeaders(b string) string
• func GetServerAddr() string
• func InitBuckets(buckets []string)
• func List(b string) <-chan minio.ObjectInfo
• func ParseDate(f string) string
• func Put(b string, k string, r []byte)
• func PutFile(b string, k string)

Constants

const (
	NBALAKE_HOST = "host"
	NBALAKE_PORT = "port"
)

const (
	NBALAKE             = "nbalake"
	NBALAKE_AUTH_KEY    = "key"
	NBALAKE_AUTH_SECRET = "secret"
	NBALAKE_CONF_DIR    = "conf_dir"
)

const (
	NBALAKE_API_DEFAULT_HOST = "localhost"
	NBALAKE_API_DEFAULT_PORT = "9000"
	NBALAKE_SERVICE          = "minio"
)

const (
	CONF_DEFAULT_DIR       = "conf"
	CONF_DEFAULT_FILE      = "config"
	CONF_DEFAULT_FILE_TYPE = "json"
)

const (
	BUCKET_RAW       = "nba.raw"
	BUCKET_ANALYTICS = "nba.analytics"
)

const (
	PREFIX_LEADERS = "leaders"
	PREFIX_SEASON  = "season"
)

const (
	STR_EMPTY  = ""
	STR_PERIOD = "."
)

const (
	CONTENT_TYPE_JSON = "application/json"
)

const (
	EXT_PARQUET = ".parquet"
)

const (
	NBALAKE_DELIMITER = "."
)

Functions

func BucketName

func BucketName(y string, id string) string

func ConnectionNew

func ConnectionNew()

func Exists

func Exists(b string, k string) bool

func Get

func Get(b string, f string) []byte

func GetLatestLeaders

func GetLatestLeaders(b string) string

func GetServerAddr

func GetServerAddr() string

func InitBuckets

func InitBuckets(buckets []string)

func List

func List(b string) <-chan minio.ObjectInfo

func ParseDate

func ParseDate(f string) string

func Put

func Put(b string, k string, r []byte)

func PutFile

func PutFile(b string, k string)