threadshelper

Documentation

Index

• Constants
• func LoadPrivateKeyFromPemFile(fileName string) (crypto.PrivKey, error)
• func SavePrivateKeyToPemFile(fileName string) (crypto.PrivKey, error)
• type ClientStruct
  • func NewClientStruct(baseThreadIdStr string) (*ClientStruct, error)
  • func (cs *ClientStruct) Close()
  • func (cs *ClientStruct) CreateBaseCollection() error
  • func (cs *ClientStruct) CreateBaseDb() (db.Info, error)
  • func (cs *ClientStruct) PublishPayload(ctx context.Context, sId multischema.SchemaId, payload []byte) (string, error)
  • func (cs *ClientStruct) RegisterSchema(ctx context.Context, record model.SchemaRecord) error

Constants

const (
	CollectionNameSchemaRecord = "SchemaRecord"
)

Functions

func LoadPrivateKeyFromPemFile

func LoadPrivateKeyFromPemFile(fileName string) (crypto.PrivKey, error)

func SavePrivateKeyToPemFile

func SavePrivateKeyToPemFile(fileName string) (crypto.PrivKey, error)

Types

type ClientStruct

type ClientStruct struct {
	BaseThreadId thread.ID
	Client       *client.Client
	Identity     thread.Identity
	Token        thread.Token
}

func NewClientStruct

func NewClientStruct(baseThreadIdStr string) (*ClientStruct, error)

func (*ClientStruct) Close

func (cs *ClientStruct) Close()

func (*ClientStruct) CreateBaseCollection

func (cs *ClientStruct) CreateBaseCollection() error

func (*ClientStruct) CreateBaseDb

func (cs *ClientStruct) CreateBaseDb() (db.Info, error)

func (*ClientStruct) PublishPayload

func (cs *ClientStruct) PublishPayload(ctx context.Context, sId multischema.SchemaId, payload []byte) (string, error)

func (*ClientStruct) RegisterSchema

func (cs *ClientStruct) RegisterSchema(ctx context.Context, record model.SchemaRecord) error