Functions — github.com/SphereSoftware/objstore

hub / github.com/SphereSoftware/objstore / functions

Functions228 in github.com/SphereSoftware/objstore

⨍ Functions 228◇ Types & classes 44

↓ 1 callersMethodRouteAPI

(store objstore.Store)

api/public.go:27

↓ 1 callersMethodRouteAPI

(store objstore.Store)

api/private.go:167

↓ 1 callersMethodSetDebug

(v bool)

objstore.go:23

↓ 1 callersMethodSetDebug

(enabled bool)

api/private.go:45

↓ 1 callersMethodStat

(key string)

storage/local.go:16

↓ 1 callersMethodStatsHandler

(store objstore.Store)

api/public.go:86

↓ 1 callersMethodSync

(ctx context.Context, nodeID string, list journal.FileMetaList)

cluster/manager.go:18

↓ 1 callersMethodSyncHandler

(store objstore.Store)

api/private.go:337

↓ 1 callersMethodUnmap

(m map[string]string)

journal/meta.go:36

↓ 1 callersMethodUnmarshalMsg

UnmarshalMsg implements msgp.Unmarshaler

journal/meta_gen.go:291

↓ 1 callersMethodVersionHandler

()

api/public.go:52

↓ 1 callersMethodWaitInbound

(timeout time.Duration)

objstore.go:25

↓ 1 callersMethodWaitOutbound

(timeout time.Duration)

objstore.go:24

↓ 1 callersMethodWrite

(key string, body io.Reader)

storage/local.go:18

↓ 1 callersMethodWrite

(key string, body io.Reader)

storage/local.go:50

↓ 1 callersMethodemitEvent

(ev *EventAnnounce, timeout time.Duration)

objstore.go:452

↓ 1 callersFunctionforEachNode

(router astranet.AstraNet, iterFunc NodeIter)

api/private.go:136

↓ 1 callersFunctionforEachNode

(router astranet.AstraNet, iterFunc NodeIter)

cluster/client.go:55

↓ 1 callersFunctiongetAddr

(host uint64, port uint32)

api/private.go:163

↓ 1 callersFunctiongetAddr

(host uint64, port uint32)

cluster/client.go:82

↓ 1 callersMethodhandleEvent

(ev *EventAnnounce, timeout time.Duration)

objstore.go:514

↓ 1 callersFunctionnewHTTPTransport

(router astranet.AstraNet)

api/private.go:97

↓ 1 callersFunctionnewHTTPTransport

(router astranet.AstraNet)

cluster/client.go:32

↓ 1 callersFunctionnewReadSeeker

(buf []byte)

storage/helpers.go:15

↓ 1 callersFunctionopenStateDB

(prefix string)

cmd/objstore/main.go:209

↓ 1 callersMethodprocessInbound

(workers int, timeout time.Duration)

objstore.go:354

↓ 1 callersMethodprocessOutbound

(workers int, emitTimeout time.Duration)

objstore.go:336

↓ 1 callersMethodsync

(timeout time.Duration)

objstore.go:201

MethodAnnounce

(ctx context.Context, nodeID string, event *EventAnnounce)

cluster/manager.go:55

storage/remote.go:140

journal/manager.go:263

MethodClose

()

journal/journal.go:48

MethodClose

()

journal/journal.go:56

MethodDecodeMsg

DecodeMsg implements msgp.Decodable

journal/meta_gen.go:10

MethodDecodeMsg

DecodeMsg implements msgp.Decodable

journal/meta_gen.go:59

MethodDecodeMsg

DecodeMsg implements msgp.Decodable

journal/meta_gen.go:402

MethodDecodeMsg

DecodeMsg implements msgp.Decodable

journal/meta_gen.go:568

journal/journal.go:103

MethodDelete

(k string)

journal/journal.go:624

journal/journal.go:205

MethodDiff

(next Journal)

journal/journal.go:383

EncodeMsg implements msgp.Encodable

journal/meta_gen.go:23

MethodEncodeMsg

EncodeMsg implements msgp.Encodable

journal/meta_gen.go:156

MethodEncodeMsg

EncodeMsg implements msgp.Encodable

journal/meta_gen.go:434

MethodEncodeMsg

EncodeMsg implements msgp.Encodable

journal/meta_gen.go:628

journal/journal.go:75

MethodExists

(k string)

journal/journal.go:612

MethodExportAll

()

journal/manager.go:247

MethodFetchObject

FetchObject retrieves an object from the remote storage, e.g. Amazon S3. This should be called only on a total cache miss, when file is not found on a

objstore.go:42

MethodFindObject

(ctx context.Context, id string, fetch bool)

objstore.go:652

MethodForEach

(fn JournalIter)

journal/manager.go:197

MethodForEachUpdate

(fn JournalIter)

journal/manager.go:222

MethodGet

(id ID)

journal/mapping.go:28

MethodGet

(k string)

journal/journal.go:61

MethodGet

(k string)

journal/journal.go:602

MethodGetObject

(key string, version ...string)

storage/remote.go:61

MethodGetObject

(ctx context.Context, nodeID string, id string)

cluster/manager.go:17

MethodGetObject

(ctx context.Context, nodeID string, id string)

cluster/manager.go:75

FunctionGetULID

GetULID constucts an Universally Unique Lexicographically Sortable Identifier. See https://github.com/oklog/ulid

journal/helpers.go:17

(key string, version ...string)

storage/remote.go:86

MethodID

()

journal/journal.go:176

MethodID

()

journal/journal.go:643

MethodInt63

()

journal/helpers.go:26

(target Journal, mapping Mapping)

journal/journal.go:160

MethodJoin

Join appends the current journal to the target one, reassigning atomically the mapping.

journal/journal.go:544

MethodJoinAll

(target ID)

journal/manager.go:138

MethodListAll

()

journal/manager.go:113

cluster/manager.go:40

MethodListObjects

(prefix string, startAfter ...string)

storage/remote.go:24

MethodListObjects

(prefix string, startAfter ...string)

storage/remote.go:106

MethodMarshalMsg

MarshalMsg implements msgp.Marshaler

journal/meta_gen.go:32

MethodMarshalMsg

MarshalMsg implements msgp.Marshaler

journal/meta_gen.go:253

MethodMarshalMsg

MarshalMsg implements msgp.Marshaler

journal/meta_gen.go:456

MethodMeta

()

journal/journal.go:164

FunctionNewClusterManager

(cli *PrivateClient, nodeID string)

cluster/manager.go:28

FunctionNewJournalManager

(db *bolt.DB)

journal/manager.go:29

FunctionNewLocalStorage

journal/mapping.go:16

FunctionNewPrivateClient

NewPrivateClient initializes a new client for the virtual network. Obtain router handle from an initialized private API server.

cluster/client.go:23

FunctionNewPrivateServer

(nodeID string, tags ...string)

api/private.go:35

FunctionNewPublicServer

(nodeID string)

api/public.go:17

FunctionNewS3Storage

(region, bucket string)

storage/remote.go:36

FunctionNewStore

(nodeID string, localStorage storage.LocalStorage, remoteStorage storage.RemoteStorage, journals journal.Jo

← previous next →101–200 of 228, ranked by callers