trinity

Documentation

Index

• func CacheBlob(url string, auth string, b []byte) (sasURL string, err error)
• func CreateAuthorization(user, passwd string) (auth string)
• func CreateAuthorizationToken(user, token string) (auth string)
• func ParseAuthorization(auth string) (user string, passwdS256 [sha256.Size]byte, err error)
• func PasswdS256Token(passwdS256 [sha256.Size]byte) (token string)
• func PasswdToken(passwd string) (token string)
• func Request[Args any, Values any](url string, action Action, args Args, content atmt.Content) (vals Values, ret atmt.Content, err error)
• func RequestCtx[Args any, Values any](ctx context.Context, url string, action Action, args Args, ...) (vals Values, ret atmt.Content, err error)
• type Action
  • func (act Action) String() (str string)
• type ArgsGetBlobCacheURL
• type ArgsGetMessage
• type ArgsPostMessage
• type ArgsQueryMessageIdsLatestCount
• type ArgsVerifyAuthorization
• type MessageID
• type RequestError
• type ValuesGetBlobCacheURL
• type ValuesGetMessage
• type ValuesPostMessage
• type ValuesQueryMessageIds
• type ValuesQueryMessageIdsLatestCount
• type ValuesVerifyAuthorization

Functions

func CacheBlob

func CacheBlob(url string, auth string, b []byte) (sasURL string, err error)

func CreateAuthorization

func CreateAuthorization(user, passwd string) (auth string)

func CreateAuthorizationToken

func CreateAuthorizationToken(user, token string) (auth string)

func ParseAuthorization

func ParseAuthorization(auth string) (user string, passwdS256 [sha256.Size]byte, err error)

func PasswdS256Token

func PasswdS256Token(passwdS256 [sha256.Size]byte) (token string)

func PasswdToken

func PasswdToken(passwd string) (token string)

func Request

func Request[Args any, Values any](url string, action Action, args Args, content atmt.Content) (vals Values, ret atmt.Content, err error)

func RequestCtx

func RequestCtx[Args any, Values any](ctx context.Context, url string, action Action, args Args, content atmt.Content) (vals Values, ret atmt.Content, err error)

Types

type Action

type Action uint8

const (
	ActionPostMessage Action = iota + 1
	ActionGetMessage
	ActionQueryMessageIdsLatestCount

	ActionGetBlobCacheURL
	ActionVerifyAuthorization
)

func (Action) String

func (act Action) String() (str string)

type ArgsGetBlobCacheURL

type ArgsGetBlobCacheURL struct {
	Auth     string `json:"auth"`
	BlobName string `json:"blob_name"`
}

type ArgsGetMessage

type ArgsGetMessage struct {
	Auth string    `json:"auth"`
	ID   MessageID `json:"id"`
}

type ArgsPostMessage

type ArgsPostMessage struct {
	Auth string `json:"auth"`
}

type ArgsQueryMessageIdsLatestCount

type ArgsQueryMessageIdsLatestCount struct {
	Auth  string `json:"auth"`
	Count int    `json:"count"`
}

type ArgsVerifyAuthorization

type ArgsVerifyAuthorization struct {
	Auth string `json:"auth"`
}

type MessageID

type MessageID = primitive.ObjectID

type RequestError

type RequestError interface {
	error
	Action() Action
	StatusCode() atmt.StatusCode
}

type ValuesGetBlobCacheURL

type ValuesGetBlobCacheURL struct {
	SasURL string `json:"sas_url"`
}

type ValuesGetMessage

type ValuesGetMessage struct {
	Sender    string    `json:"sender"`
	MessageID MessageID `json:"message_id"`
}

type ValuesPostMessage

type ValuesPostMessage struct {
	MessageID MessageID `json:"message_id"`
}

type ValuesQueryMessageIds

type ValuesQueryMessageIds struct {
	Ids []MessageID `json:"ids"`
}

type ValuesQueryMessageIdsLatestCount

type ValuesQueryMessageIdsLatestCount = ValuesQueryMessageIds

type ValuesVerifyAuthorization

type ValuesVerifyAuthorization struct {
	Pass bool `json:"pass"`
}