pangea

package

Go to main page

Versions in this module

v3

v3.12.0

Oct 15, 2024

v3.11.0

Sep 26, 2024

Changes in this version

+ func GetFileSize(input *os.File) (int64, error)

+ type FileUploader struct

+ func NewFileUploader() FileUploader

+ func (fu *FileUploader) UploadFile(ctx context.Context, url string, tm TransferMethod, fd FileData) error

+ type UploadFileParams struct

+ CRC32C string

+ SHA256 string

+ Size int

+ func GetUploadFileParams(input io.ReadSeeker) (*UploadFileParams, error)

v3.10.0

Jul 19, 2024

Changes in this version

+ var ErrDecryptionFailed = errors.New("decryption failed")

+ var ErrInvalidPrivateKey = errors.New("invalid private key")

+ var ErrInvalidPublicKey = errors.New("invalid public key")

v3.9.0

Jun 7, 2024

v3.8.0

May 10, 2024

Changes in this version

+ type AttachedFile struct

+ ContentType string

+ File []byte

+ Filename string

+ func (af AttachedFile) Save(info AttachedFileSaveInfo) error

+ type AttachedFileSaveInfo struct

+ Filename string

+ Folder string

type BaseService

+ func (bs *BaseService) DownloadFile(ctx context.Context, url string) (*AttachedFile, error)

type BaseServicer

+ DownloadFile func(ctx context.Context, url string) (*AttachedFile, error)

type Client

+ func (c *Client) DownloadFile(ctx context.Context, url string) (*AttachedFile, error)

type Response

+ AttachedFiles []AttachedFile

type TransferMethod

+ const TMdestURL

v3.8.0-beta.3

Mar 25, 2024

v3.8.0-beta.2

Mar 20, 2024

v3.8.0-beta.1

Mar 18, 2024

v3.7.0

Feb 26, 2024

v3.6.0

Jan 16, 2024

Changes in this version

type Response

+ func (r Response) MarshalJSON() ([]byte, error)

v3.5.0

Dec 18, 2023

v3.4.0

Dec 7, 2023

Changes in this version

+ const TMsourceURL

type AcceptedResult

+ Location string

+ PostFormData map[string]string

+ PostURL string

+ PutURL string

+ RetryCounter int

+ TTLMins int

+ func (ar AcceptedResult) HasUploadURL() bool

v3.3.0

Nov 28, 2023

Changes in this version

+ const TMpostURL

+ const TMputURL

type Client

+ func (c *Client) FullPostPresignedURL(ctx context.Context, url string, input ConfigIDer, out any, fd FileData) (*Response, error)

+ func (c *Client) GetPresignedURL(ctx context.Context, url string, input any) (*Response, *AcceptedResult, error)

+ func (c *Client) UploadFile(ctx context.Context, url string, tm TransferMethod, fd FileData) error

+ type FileData struct

+ Details map[string]string

+ File io.Reader

+ Name string

v3.2.0

Nov 16, 2023

Changes in this version

type PangeaResponse

+ AcceptedResult *AcceptedResult

v3.1.0

Nov 9, 2023

Changes in this version

type AcceptedError

+ AcceptedResult AcceptedResult

+ type AcceptedResult struct

+ AcceptedStatus AcceptedStatus

+ type AcceptedStatus struct

+ UploadDetails map[string]string

+ UploadURL string

type Client

+ func (c *Client) GetRequestIDURL(rid string) (string, error)

+ func (c *Client) GetURL(path string) (string, error)

+ func (c *Client) NewRequestForm(method, url string, body map[string]string, file io.Reader, setHeaders bool) (*http.Request, error)

+ func (c *Client) NewRequestMultipart(method, url string, body any, file io.Reader) (*http.Request, error)

+ func (c *Client) PostMultipart(ctx context.Context, url string, input any, out any, file io.Reader) (*Response, error)

+ func (c *Client) PostPresignedURL(ctx context.Context, url string, input any, out any, file io.Reader) (*Response, error)

+ func (c *Client) ServiceName() string

+ type TransferMethod string

+ const TMdirect

+ const TMmultipart

+ type TransferRequest struct

+ TransferMethod TransferMethod

+ func (tr TransferRequest) GetTransferMethod() TransferMethod

+ type TransferRequester interface

+ GetTransferMethod func() TransferMethod

v3.0.0

Oct 23, 2023

Changes in this version

+ func B64ToStr(enc string) ([]byte, error)

+ func Bool(v bool) *bool

+ func BoolValue(v *bool) bool

+ func GetDefaultPangeaLogger() *zerolog.Logger

+ func GetHashPrefix(h string, len uint) string

+ func HashSHA1(i string) string

+ func HashSHA256(i string) string

+ func HashSHA512(i string) string

+ func Int(v int) *int

+ func IntValue(v *int) int

+ func PangeaTime(v pu.PangeaTimestamp) *pu.PangeaTimestamp

+ func StrToB64(dec string) string

+ func String(v string) *string

+ func StringValue(v *string) string

+ func Stringify(obj interface{}) string

+ func StringifyIndented(obj interface{}) string

+ func Time(v time.Time) *time.Time

+ type APIError struct

+ PangeaErrors PangeaErrors

+ RawResult json.RawMessage

+ ResponseHeader *ResponseHeader

+ func NewAPIError(err error, r *Response) *APIError

+ func (e *APIError) Error() string

+ type AcceptedError struct

+ ResultField any

+ func (e *AcceptedError) Error() string

+ func (e *AcceptedError) Is(target error) bool

+ func (e *AcceptedError) ReqID() string

+ type BaseError struct

+ Err error

+ HTTPResponse *http.Response

+ func (e *BaseError) Error() string

+ type BaseRequest struct

+ ConfigID string

+ func (br *BaseRequest) GetConfigID() string

+ func (br *BaseRequest) SetConfigID(c string)

+ type BaseService struct

+ Client *Client

+ func NewBaseService(name string, baseCfg *Config) BaseService

+ func (bs *BaseService) GetPendingRequestID() []string

+ func (bs *BaseService) PollResultByError(ctx context.Context, e AcceptedError) (*PangeaResponse[any], error)

+ func (bs *BaseService) PollResultByID(ctx context.Context, rid string, v any) (*PangeaResponse[any], error)

+ func (bs *BaseService) PollResultRaw(ctx context.Context, rid string) (*PangeaResponse[map[string]any], error)

+ type BaseServicer interface

+ GetPendingRequestID func() []string

+ PollResultByError func(ctx context.Context, e AcceptedError) (*PangeaResponse[any], error)

+ PollResultByID func(ctx context.Context, rid string, v any) (*PangeaResponse[any], error)

+ PollResultRaw func(ctx context.Context, requestID string) (*PangeaResponse[map[string]any], error)

+ type Client struct

+ Logger zerolog.Logger

+ func NewClient(service string, baseCfg *Config, additionalConfigs ...*Config) *Client

+ func (c *Client) BareDo(ctx context.Context, req *http.Request) (*http.Response, error)

+ func (c *Client) CheckResponse(r *Response, v any) error

+ func (c *Client) Do(ctx context.Context, req *http.Request, v any) (*Response, error)

+ func (c *Client) FetchAcceptedResponse(ctx context.Context, reqID string, v interface{}) (*Response, error)

+ func (c *Client) GetPendingRequestID() []string

+ func (c *Client) NewRequest(method, urlStr string, body ConfigIDer) (*http.Request, error)

+ func (c *Client) NewRequestMultPart(method, urlStr string, body interface{}, file io.Reader) (*http.Request, error)

+ func (c *Client) SetHeaders(req *http.Request)

+ type ClientOption func(*Client) error

+ func ClientWithConfigID(cid string) ClientOption

+ type Config struct

+ AdditionalHeaders map[string]string

+ ConfigID string

+ CustomUserAgent string

+ Domain string

+ Enviroment string

+ HTTPClient *http.Client

+ Insecure bool

+ Logger *zerolog.Logger

+ PollResultTimeout time.Duration

+ QueuedRetryEnabled bool

+ Retry bool

+ RetryConfig *RetryConfig

+ Token string

+ func (c *Config) Copy(cfgs ...*Config) *Config

+ func (c *Config) MergeIn(cfgs ...*Config)

+ type ConfigIDer interface

+ GetConfigID func() string

+ SetConfigID func(configID string)

+ type ErrorField struct

+ Code string

+ Detail string

+ Path string

+ Source string

+ type Filter map[string]any

+ type FilterBase struct

+ func NewFilterBase(f Filter) *FilterBase

+ func (fb FilterBase) Filter() Filter

+ type FilterCommon struct

+ type FilterEqual struct

+ func NewFilterEqual(name string, filter *Filter) *FilterEqual[T]

+ func (f *FilterEqual[T]) Get() *T

+ func (f *FilterEqual[T]) Set(value *T)

+ type FilterMatch struct

+ func NewFilterMatch(name string, filter *Filter) *FilterMatch[T]

+ func (f *FilterMatch[T]) Contains() []T

+ func (f *FilterMatch[T]) In() []T

+ func (f *FilterMatch[T]) SetContains(value []T)

+ func (f *FilterMatch[T]) SetIn(value []T)

+ type FilterRange struct

+ func NewFilterRange(name string, filter *Filter) *FilterRange[T]

+ func (f *FilterRange[T]) GreaterThan() *T

+ func (f *FilterRange[T]) GreaterThanEqual() *T

+ func (f *FilterRange[T]) LessThan() *T

+ func (f *FilterRange[T]) LessThanEqual() *T

+ func (f *FilterRange[T]) SetGreaterThan(value *T)

+ func (f *FilterRange[T]) SetGreaterThanEqual(value *T)

+ func (f *FilterRange[T]) SetLessThan(value *T)

+ func (f *FilterRange[T]) SetLessThanEqual(value *T)

+ type Option func(*BaseService) error

+ func WithConfigID(cid string) Option

+ type PangeaErrors struct

+ Errors []ErrorField

+ type PangeaResponse struct

+ Result *T

+ type Response struct

+ HTTPResponse *http.Response

+ RawResult json.RawMessage

+ func (r *Response) UnmarshalResult(target interface{}) error

+ type ResponseHeader struct

+ RequestID *string

+ RequestTime *string

+ ResponseTime *string

+ Status *string

+ Summary *string

+ func (r *ResponseHeader) String() string

+ type RetryConfig struct

+ BackOff float32

+ RetryMax int

+ RetryWaitMax time.Duration

+ RetryWaitMin time.Duration

+ type UnmarshalError struct

+ Bytes []byte

+ func NewUnmarshalError(err error, bytes []byte, r *http.Response) *UnmarshalError

+ func (e *UnmarshalError) Error() string

Other modules containing this package

github.com/pangeacyber/pangea-go/pangea-sdk

github.com/pangeacyber/pangea-go/pangea-sdk/v2

github.com/pangeacyber/pangea-go/pangea-sdk/v4

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL