shiroclient

Feb 27, 2024

Changes in this version

type Config

+ func WithTargetEndpoints(nameOrURL []string) Config

Dec 13, 2023

Changes in this version

type Config

+ func WithJaegerTracing(collectorURI, datasetID string) Config

Dec 1, 2023

Changes in this version

type Config

+ func WithDependentBlock(block string) Config

+ func WithHTTPClient(client *http.Client) Config

+ func WithPhylumVersion(phylumVersion string) Config

Jul 24, 2023

Changes in this version

+ func UnmarshalProto(src []byte, dst interface{}) error

type Config

+ func WithSingleton() Config

+ Fn func(*requestOptions)

May 25, 2022

Changes in this version

+ type HealthCheck interface

+ Reports func() []HealthCheckReport

+ func RemoteHealthCheck(ctx context.Context, client ShiroClient, services []string, configs ...Config) (HealthCheck, error)

+ type HealthCheckReport interface

+ ServiceName func() string

+ ServiceVersion func() string

+ Status func() string

+ Timestamp func() string

Mar 29, 2022

Changes in this version

+ const ErrorCodeShiroClientNone

+ const ErrorCodeShiroClientTimeout

+ const ErrorLevelNoError

+ const ErrorLevelPhylum

+ const ErrorLevelShiroClient

+ const MethodCall

+ const MethodInit

+ const MethodQueryBlock

+ const MethodQueryInfo

+ const MethodSeed

+ const MethodShiroPhylum

+ func EncodePhylumBytes(decoded []byte) string

+ func IsTimeoutError(err error) bool

+ func ProbeForCall(configs []Config) (context.Context, string, func(context.Context) string, logrus.Fields, string, ...)

+ func ProbeForNew(configs []Config) (bool, *url.URL, error)

+ type Block interface

+ Hash func() string

+ Transactions func() []Transaction

+ type Config func(*requestOptions)

+ func WithAuthToken(token string) Config

+ func WithCCFetchURLDowngrade(downgrade bool) Config

+ func WithCCFetchURLProxy(proxy *url.URL) Config

+ func WithContext(ctx context.Context) Config

+ func WithCreator(creator string) Config

+ func WithDependentTxID(txID string) Config

+ func WithDisableWritePolling(disable bool) Config

+ func WithEndpoint(endpoint string) Config

+ func WithHeader(key string, value string) Config

+ func WithID(id string) Config

+ func WithLog(log *logrus.Logger) Config

+ func WithLogField(key string, value interface{}) Config

+ func WithLogrusFields(fields logrus.Fields) Config

+ func WithMSPFilter(mspFilter []string) Config

+ func WithMinEndorsers(minEndorsers int) Config

+ func WithParams(params interface{}) Config

+ func WithResponse(target *interface{}) Config

+ func WithTimestampGenerator(timestampGenerator func(context.Context) string) Config

+ func WithTransientData(key string, val []byte) Config

+ func WithTransientDataMap(data map[string][]byte) Config

+ type Error interface

+ Code func() int

+ DataJSON func() []byte

+ Message func() string

+ type MockShiroClient interface

+ Close func() error

+ SetCreatorWithAttributes func(creator string, attrs map[string]string) error

+ Snapshot func(w io.Writer) error

+ func NewMock(clientConfigs []Config, opts ...mock.Option) (MockShiroClient, error)

+ type ShiroClient interface

+ Call func(ctx context.Context, method string, config ...Config) (ShiroResponse, error)

+ Init func(phylum string, config ...Config) error

+ QueryBlock func(blockNumber uint64, config ...Config) (Block, error)

+ QueryInfo func(config ...Config) (uint64, error)

+ Seed func(version string, config ...Config) error

+ ShiroPhylum func(config ...Config) (string, error)

+ func NewRPC(clientConfigs []Config) ShiroClient

+ type ShiroResponse interface

+ Error func() Error

+ ResultJSON func() []byte

+ TransactionID func() string

+ UnmarshalTo func(dst interface{}) error

+ type Transaction interface

+ ChaincodeID func() string

+ Event func() []byte

+ ID func() string

+ Reason func() string