gateway

Apr 4, 2022

Changes in this version

+ var ErrInvokeMethodNotAllowed = errors.New(`invoke method not allowed`)

+ func InvokerArgs(fn string, args []interface{}) ([][]byte, error)

type ChaincodeEvent

+ func ProcessEvent(event interface{ ... }, opts []EventOpt, matchName []string) (*ChaincodeEvent, error)

type ChaincodeEventService

+ func (ce *ChaincodeEventService) EventsChan(ctx context.Context, req *ChaincodeEventsStreamRequest) (_ chan *ChaincodeEvent, closer func() error, _ error)

type ChaincodeEvents

+ Locator *ChaincodeLocator

+ func (x *ChaincodeEvents) GetLocator() *ChaincodeLocator

type ChaincodeEventsRequest

+ Locator *ChaincodeLocator

+ func (x *ChaincodeEventsRequest) GetLocator() *ChaincodeLocator

type ChaincodeEventsStreamRequest

+ Locator *ChaincodeLocator

+ func (x *ChaincodeEventsStreamRequest) GetLocator() *ChaincodeLocator

+ type ChaincodeExecRequest struct

+ Input *ChaincodeInput

+ Locator *ChaincodeLocator

+ Type InvocationType

+ func (*ChaincodeExecRequest) Descriptor() ([]byte, []int)

+ func (*ChaincodeExecRequest) ProtoMessage()

+ func (this *ChaincodeExecRequest) Validate() error

+ func (x *ChaincodeExecRequest) GetInput() *ChaincodeInput

+ func (x *ChaincodeExecRequest) GetLocator() *ChaincodeLocator

+ func (x *ChaincodeExecRequest) GetType() InvocationType

+ func (x *ChaincodeExecRequest) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeExecRequest) Reset()

+ func (x *ChaincodeExecRequest) String() string

+ type ChaincodeInstance interface

+ EventsChan func(ctx context.Context, rr ...*ChaincodeInstanceEventsStreamRequest) (_ chan *ChaincodeEvent, closer func() error, _ error)

type ChaincodeInstanceEventService

+ EventDelivery sdk.EventDelivery

+ Logger *zap.Logger

+ Opts *Opts

+ func (ces *ChaincodeInstanceEventService) EventsChan(ctx context.Context, rr ...*ChaincodeInstanceEventsStreamRequest) (_ chan *ChaincodeEvent, closer func() error, _ error)

+ type ChaincodeInstanceEvents interface

+ EventsChan func(ctx context.Context, rr ...*ChaincodeInstanceEventsStreamRequest) (_ chan *ChaincodeEvent, closer func() error, _ error)

+ type ChaincodeInstanceExecRequest struct

+ Input *ChaincodeInput

+ Type InvocationType

+ func (*ChaincodeInstanceExecRequest) Descriptor() ([]byte, []int)

+ func (*ChaincodeInstanceExecRequest) ProtoMessage()

+ func (this *ChaincodeInstanceExecRequest) Validate() error

+ func (x *ChaincodeInstanceExecRequest) GetInput() *ChaincodeInput

+ func (x *ChaincodeInstanceExecRequest) GetType() InvocationType

+ func (x *ChaincodeInstanceExecRequest) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeInstanceExecRequest) Reset()

+ func (x *ChaincodeInstanceExecRequest) String() string

+ type ChaincodeInstanceInvokeRequest struct

+ Input *ChaincodeInput

+ func (*ChaincodeInstanceInvokeRequest) Descriptor() ([]byte, []int)

+ func (*ChaincodeInstanceInvokeRequest) ProtoMessage()

+ func (this *ChaincodeInstanceInvokeRequest) Validate() error

+ func (x *ChaincodeInstanceInvokeRequest) GetInput() *ChaincodeInput

+ func (x *ChaincodeInstanceInvokeRequest) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeInstanceInvokeRequest) Reset()

+ func (x *ChaincodeInstanceInvokeRequest) String() string

+ type ChaincodeInstanceInvoker interface

+ Invoke func(ctx context.Context, fn string, args []interface{}, target interface{}) (interface{}, error)

+ Query func(ctx context.Context, fn string, args []interface{}, target interface{}) (interface{}, error)

+ type ChaincodeInstanceQueryRequest struct

+ Input *ChaincodeInput

+ func (*ChaincodeInstanceQueryRequest) Descriptor() ([]byte, []int)

+ func (*ChaincodeInstanceQueryRequest) ProtoMessage()

+ func (this *ChaincodeInstanceQueryRequest) Validate() error

+ func (x *ChaincodeInstanceQueryRequest) GetInput() *ChaincodeInput

+ func (x *ChaincodeInstanceQueryRequest) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeInstanceQueryRequest) Reset()

+ func (x *ChaincodeInstanceQueryRequest) String() string

type ChaincodeInstanceService

+ Opts *Opts

+ SDK sdk.SDK

+ func (cis *ChaincodeInstanceService) EventsChan(ctx context.Context, rr ...*ChaincodeInstanceEventsStreamRequest) (_ chan *ChaincodeEvent, closer func() error, _ error)

+ type ChaincodeInstanceServiceInvoker struct

+ ChaincodeInstance ChaincodeInstanceServiceServer

+ func NewChaincodeInstanceServiceInvoker(ccInstance ChaincodeInstanceServiceServer) *ChaincodeInstanceServiceInvoker

+ func (c *ChaincodeInstanceServiceInvoker) Invoke(ctx context.Context, fn string, args []interface{}, target interface{}) (interface{}, error)

+ func (c *ChaincodeInstanceServiceInvoker) Query(ctx context.Context, fn string, args []interface{}, target interface{}) (interface{}, error)

+ type ChaincodeInvokeRequest struct

+ Input *ChaincodeInput

+ Locator *ChaincodeLocator

+ func (*ChaincodeInvokeRequest) Descriptor() ([]byte, []int)

+ func (*ChaincodeInvokeRequest) ProtoMessage()

+ func (this *ChaincodeInvokeRequest) Validate() error

+ func (x *ChaincodeInvokeRequest) GetInput() *ChaincodeInput

+ func (x *ChaincodeInvokeRequest) GetLocator() *ChaincodeLocator

+ func (x *ChaincodeInvokeRequest) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeInvokeRequest) Reset()

+ func (x *ChaincodeInvokeRequest) String() string

+ type ChaincodeLocatorResolver func(ctx router.Context, serviceName string) (*ChaincodeLocator, error)

+ type ChaincodeQueryRequest struct

+ Input *ChaincodeInput

+ Locator *ChaincodeLocator

+ func (*ChaincodeQueryRequest) Descriptor() ([]byte, []int)

+ func (*ChaincodeQueryRequest) ProtoMessage()

+ func (this *ChaincodeQueryRequest) Validate() error

+ func (x *ChaincodeQueryRequest) GetInput() *ChaincodeInput

+ func (x *ChaincodeQueryRequest) GetLocator() *ChaincodeLocator

+ func (x *ChaincodeQueryRequest) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeQueryRequest) Reset()

+ func (x *ChaincodeQueryRequest) String() string

type ChaincodeService

+ func (cs *ChaincodeService) EventsChan(ctx context.Context, req *ChaincodeEventsStreamRequest) (_ chan *ChaincodeEvent, closer func() error, _ error)

+ type ChaincodeStubInvoker interface

+ Query func(stub shim.ChaincodeStubInterface, fn string, args []interface{}, ...) (interface{}, error)

+ type InstanceOpts struct

+ Locator *ChaincodeLocator

+ Opts Opts

type InvocationType

+ const InvocationType_INVOCATION_TYPE_INVOKE

+ const InvocationType_INVOCATION_TYPE_QUERY

+ type LocatorChaincodeStubInvoker struct

+ Locator *ChaincodeLocator

+ func (c *LocatorChaincodeStubInvoker) Query(stub shim.ChaincodeStubInterface, fn string, args []interface{}, ...) (interface{}, error)

type Opt

+ func WithDefaultTransientMapValue(key string, value []byte) Opt

+ type Service interface

+ GRPCDesc func() *grpc.ServiceDesc

+ GRPCGatewayRegister func() RegisterHandlerFromEndpoint

+ Impl func() interface{}

+ Name func() string

+ Swagger func() []byte

type ServiceDef

+ func NewServiceDef(name string, swagger []byte, desc *grpc.ServiceDesc, service interface{}, ...) ServiceDef

+ func (s ServiceDef) GRPCDesc() *grpc.ServiceDesc

+ func (s ServiceDef) GRPCGatewayRegister() RegisterHandlerFromEndpoint

+ func (s ServiceDef) Impl() interface{}

+ func (s ServiceDef) Name() string

+ func (s ServiceDef) Swagger() []byte

Jan 20, 2022

Changes in this version

+ const EventListStreamTimeout

+ func MatchEventName(eventName string, expectedNames []string) bool

+ type BlockLimit struct

+ Num int64

+ func (*BlockLimit) Descriptor() ([]byte, []int)

+ func (*BlockLimit) ProtoMessage()

+ func (this *BlockLimit) Validate() error

+ func (x *BlockLimit) GetNum() int64

+ func (x *BlockLimit) ProtoReflect() protoreflect.Message

+ func (x *BlockLimit) Reset()

+ func (x *BlockLimit) String() string

+ type ChaincodeEvent struct

+ Block uint64

+ Event *peer.ChaincodeEvent

+ Payload *RawJson

+ TxTimestamp *timestamp.Timestamp

+ func (*ChaincodeEvent) Descriptor() ([]byte, []int)

+ func (*ChaincodeEvent) ProtoMessage()

+ func (this *ChaincodeEvent) Validate() error

+ func (x *ChaincodeEvent) GetBlock() uint64

+ func (x *ChaincodeEvent) GetEvent() *peer.ChaincodeEvent

+ func (x *ChaincodeEvent) GetPayload() *RawJson

+ func (x *ChaincodeEvent) GetTxTimestamp() *timestamp.Timestamp

+ func (x *ChaincodeEvent) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeEvent) Reset()

+ func (x *ChaincodeEvent) String() string

type ChaincodeEventService

+ Opts *Opts

+ func (ce *ChaincodeEventService) EventsStream(req *ChaincodeEventsStreamRequest, ...) error

+ type ChaincodeEvents struct

+ Chaincode *ChaincodeLocator

+ FromBlock *BlockLimit

+ Items []*ChaincodeEvent

+ ToBlock *BlockLimit

+ func (*ChaincodeEvents) Descriptor() ([]byte, []int)

+ func (*ChaincodeEvents) ProtoMessage()

+ func (this *ChaincodeEvents) Validate() error

+ func (x *ChaincodeEvents) GetChaincode() *ChaincodeLocator

+ func (x *ChaincodeEvents) GetFromBlock() *BlockLimit

+ func (x *ChaincodeEvents) GetItems() []*ChaincodeEvent

+ func (x *ChaincodeEvents) GetToBlock() *BlockLimit

+ func (x *ChaincodeEvents) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeEvents) Reset()

+ func (x *ChaincodeEvents) String() string

type ChaincodeEventsRequest

+ EventName []string

+ FromBlock *BlockLimit

+ Limit uint32

+ ToBlock *BlockLimit

+ func (x *ChaincodeEventsRequest) GetEventName() []string

+ func (x *ChaincodeEventsRequest) GetFromBlock() *BlockLimit

+ func (x *ChaincodeEventsRequest) GetLimit() uint32

+ func (x *ChaincodeEventsRequest) GetToBlock() *BlockLimit

type ChaincodeEventsServiceClient

+ EventsStream func(ctx context.Context, in *ChaincodeEventsStreamRequest, opts ...grpc.CallOption) (ChaincodeEventsService_EventsStreamClient, error)

type ChaincodeEventsServiceServer

+ EventsStream func(*ChaincodeEventsStreamRequest, ChaincodeEventsService_EventsStreamServer) error

+ type ChaincodeEventsService_EventsStreamClient interface

+ Recv func() (*ChaincodeEvent, error)

+ type ChaincodeEventsService_EventsStreamServer interface

+ Send func(*ChaincodeEvent) error

+ type ChaincodeEventsStreamRequest struct

+ Chaincode *ChaincodeLocator

+ EventName []string

+ FromBlock *BlockLimit

+ ToBlock *BlockLimit

+ func (*ChaincodeEventsStreamRequest) Descriptor() ([]byte, []int)

+ func (*ChaincodeEventsStreamRequest) ProtoMessage()

+ func (this *ChaincodeEventsStreamRequest) Validate() error

+ func (x *ChaincodeEventsStreamRequest) GetChaincode() *ChaincodeLocator

+ func (x *ChaincodeEventsStreamRequest) GetEventName() []string

+ func (x *ChaincodeEventsStreamRequest) GetFromBlock() *BlockLimit

+ func (x *ChaincodeEventsStreamRequest) GetToBlock() *BlockLimit

+ func (x *ChaincodeEventsStreamRequest) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeEventsStreamRequest) Reset()

+ func (x *ChaincodeEventsStreamRequest) String() string

type ChaincodeInstanceEventService

+ func (ces *ChaincodeInstanceEventService) EventsStream(request *ChaincodeInstanceEventsStreamRequest, ...) error

type ChaincodeInstanceEventsRequest

+ EventName []string

+ FromBlock *BlockLimit

+ Limit uint32

+ ToBlock *BlockLimit

+ func (x *ChaincodeInstanceEventsRequest) GetEventName() []string

+ func (x *ChaincodeInstanceEventsRequest) GetFromBlock() *BlockLimit

+ func (x *ChaincodeInstanceEventsRequest) GetLimit() uint32

+ func (x *ChaincodeInstanceEventsRequest) GetToBlock() *BlockLimit

type ChaincodeInstanceEventsServiceClient

+ EventsStream func(ctx context.Context, in *ChaincodeInstanceEventsStreamRequest, ...) (ChaincodeInstanceEventsService_EventsStreamClient, error)

type ChaincodeInstanceEventsServiceServer

+ EventsStream func(*ChaincodeInstanceEventsStreamRequest, ...) error

+ type ChaincodeInstanceEventsService_EventsStreamClient interface

+ Recv func() (*ChaincodeEvent, error)

+ type ChaincodeInstanceEventsService_EventsStreamServer interface

+ Send func(*ChaincodeEvent) error

+ type ChaincodeInstanceEventsStreamRequest struct

+ EventName []string

+ FromBlock *BlockLimit

+ ToBlock *BlockLimit

+ func (*ChaincodeInstanceEventsStreamRequest) Descriptor() ([]byte, []int)

+ func (*ChaincodeInstanceEventsStreamRequest) ProtoMessage()

+ func (this *ChaincodeInstanceEventsStreamRequest) Validate() error

+ func (x *ChaincodeInstanceEventsStreamRequest) GetEventName() []string

+ func (x *ChaincodeInstanceEventsStreamRequest) GetFromBlock() *BlockLimit

+ func (x *ChaincodeInstanceEventsStreamRequest) GetToBlock() *BlockLimit

+ func (x *ChaincodeInstanceEventsStreamRequest) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeInstanceEventsStreamRequest) Reset()

+ func (x *ChaincodeInstanceEventsStreamRequest) String() string

type ChaincodeInstanceService

+ func (cis *ChaincodeInstanceService) EventsStream(request *ChaincodeInstanceEventsStreamRequest, ...) error

type ChaincodeInstanceServiceClient

+ EventsStream func(ctx context.Context, in *ChaincodeInstanceEventsStreamRequest, ...) (ChaincodeInstanceService_EventsStreamClient, error)

type ChaincodeInstanceServiceServer

+ EventsStream func(*ChaincodeInstanceEventsStreamRequest, ...) error

+ type ChaincodeInstanceService_EventsStreamClient interface

+ Recv func() (*peer.ChaincodeEvent, error)

+ type ChaincodeInstanceService_EventsStreamServer interface

+ Send func(*peer.ChaincodeEvent) error

type ChaincodeService

+ Opts *Opts

+ SDK sdk.SDK

+ func (cs *ChaincodeService) EventsStream(req *ChaincodeEventsStreamRequest, stream ChaincodeService_EventsStreamServer) error

type ChaincodeServiceClient

+ EventsStream func(ctx context.Context, in *ChaincodeEventsStreamRequest, opts ...grpc.CallOption) (ChaincodeService_EventsStreamClient, error)

type ChaincodeServiceServer

+ EventsStream func(*ChaincodeEventsStreamRequest, ChaincodeService_EventsStreamServer) error

+ type ChaincodeService_EventsStreamClient interface

+ Recv func() (*ChaincodeEvent, error)

+ type ChaincodeService_EventsStreamServer interface

+ Send func(*ChaincodeEvent) error

type Opt

+ func WithEventResolver(resolver mapping.EventResolver) Opt

+ type Opts struct

+ Context []ContextOpt

+ Event []EventOpt

+ Input []InputOpt

+ Output []OutputOpt

+ type RawJson struct

+ Value []byte

+ func (*RawJson) Descriptor() ([]byte, []int)

+ func (*RawJson) ProtoMessage()

+ func (this *RawJson) Validate() error

+ func (x *RawJson) GetValue() []byte

+ func (x *RawJson) MarshalJSON() ([]byte, error)

+ func (x *RawJson) MarshalJSONPB(_ *jsonpb.Marshaler) ([]byte, error)

+ func (x *RawJson) ProtoReflect() protoreflect.Message

+ func (x *RawJson) Reset()

+ func (x *RawJson) String() string

type UnimplementedChaincodeEventsServiceServer

+ func (*UnimplementedChaincodeEventsServiceServer) EventsStream(*ChaincodeEventsStreamRequest, ChaincodeEventsService_EventsStreamServer) error

type UnimplementedChaincodeInstanceEventsServiceServer

+ func (*UnimplementedChaincodeInstanceEventsServiceServer) EventsStream(*ChaincodeInstanceEventsStreamRequest, ...) error

type UnimplementedChaincodeInstanceServiceServer

+ func (*UnimplementedChaincodeInstanceServiceServer) EventsStream(*ChaincodeInstanceEventsStreamRequest, ...) error

type UnimplementedChaincodeServiceServer

+ func (*UnimplementedChaincodeServiceServer) EventsStream(*ChaincodeEventsStreamRequest, ChaincodeService_EventsStreamServer) error

Dec 15, 2021

Changes in this version

+ const CtxSignerKey

+ const CtxTxWaiterKey

+ var ErrChaincodeNotExists = errors.New(`chaincode not exists`)

+ var ErrSignerNotDefinedInContext = errors.New(`signer is not defined in context`)

+ var ErrUnknownInvocationType = errors.New(`unknown invocation type`)

+ var File_chaincode_proto protoreflect.FileDescriptor

+ var InvocationType_name = map[int32]string

+ var InvocationType_value = map[string]int32

+ func ContextWithDefaultSigner(ctx context.Context, defaultSigner msp.SigningIdentity) context.Context

+ func ContextWithSigner(ctx context.Context, signer msp.SigningIdentity) context.Context

+ func ContextWithTxWaiter(ctx context.Context, txWaiterType string) context.Context

+ func RegisterChaincodeEventsServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterChaincodeEventsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, ...) error

+ func RegisterChaincodeEventsServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterChaincodeEventsServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, ...) error

+ func RegisterChaincodeEventsServiceServer(s *grpc.Server, srv ChaincodeEventsServiceServer)

+ func RegisterChaincodeInstanceEventsServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterChaincodeInstanceEventsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, ...) error

+ func RegisterChaincodeInstanceEventsServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterChaincodeInstanceEventsServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, ...) error

+ func RegisterChaincodeInstanceEventsServiceServer(s *grpc.Server, srv ChaincodeInstanceEventsServiceServer)

+ func RegisterChaincodeInstanceServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterChaincodeInstanceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, ...) error

+ func RegisterChaincodeInstanceServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterChaincodeInstanceServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, ...) error

+ func RegisterChaincodeInstanceServiceServer(s *grpc.Server, srv ChaincodeInstanceServiceServer)

+ func RegisterChaincodeServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterChaincodeServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ChaincodeServiceClient) error

+ func RegisterChaincodeServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterChaincodeServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ChaincodeServiceServer) error

+ func RegisterChaincodeServiceServer(s *grpc.Server, srv ChaincodeServiceServer)

+ func SignerFromContext(ctx context.Context) (msp.SigningIdentity, error)

+ func TxWaiterFromContext(ctx context.Context) string

+ type BlockRange struct

+ From int64

+ To int64

+ func (*BlockRange) Descriptor() ([]byte, []int)

+ func (*BlockRange) ProtoMessage()

+ func (this *BlockRange) Validate() error

+ func (x *BlockRange) GetFrom() int64

+ func (x *BlockRange) GetTo() int64

+ func (x *BlockRange) ProtoReflect() protoreflect.Message

+ func (x *BlockRange) Reset()

+ func (x *BlockRange) String() string

+ type ChaincodeEventService struct

+ EventDelivery EventDelivery

+ func NewChaincodeEventService(eventDelivery EventDelivery) *ChaincodeEventService

+ func (ce *ChaincodeEventService) Events(in *ChaincodeEventsRequest, stream ChaincodeService_EventsServer) error

+ func (ce *ChaincodeEventService) ServiceDef() ServiceDef

+ type ChaincodeEventsRequest struct

+ Block *BlockRange

+ Chaincode *ChaincodeLocator

+ func (*ChaincodeEventsRequest) Descriptor() ([]byte, []int)

+ func (*ChaincodeEventsRequest) ProtoMessage()

+ func (this *ChaincodeEventsRequest) Validate() error

+ func (x *ChaincodeEventsRequest) GetBlock() *BlockRange

+ func (x *ChaincodeEventsRequest) GetChaincode() *ChaincodeLocator

+ func (x *ChaincodeEventsRequest) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeEventsRequest) Reset()

+ func (x *ChaincodeEventsRequest) String() string

+ type ChaincodeEventsServer = chaincodeServiceEventsServer

+ type ChaincodeEventsServiceClient interface

+ Events func(ctx context.Context, in *ChaincodeEventsRequest, opts ...grpc.CallOption) (ChaincodeEventsService_EventsClient, error)

+ func NewChaincodeEventsServiceClient(cc grpc.ClientConnInterface) ChaincodeEventsServiceClient

+ type ChaincodeEventsServiceServer interface

+ Events func(*ChaincodeEventsRequest, ChaincodeEventsService_EventsServer) error

+ type ChaincodeEventsService_EventsClient interface

+ Recv func() (*peer.ChaincodeEvent, error)

+ type ChaincodeEventsService_EventsServer interface

+ Send func(*peer.ChaincodeEvent) error

+ type ChaincodeExec struct

+ Input *ChaincodeInput

+ Type InvocationType

+ func (*ChaincodeExec) Descriptor() ([]byte, []int)

+ func (*ChaincodeExec) ProtoMessage()

+ func (this *ChaincodeExec) Validate() error

+ func (x *ChaincodeExec) GetInput() *ChaincodeInput

+ func (x *ChaincodeExec) GetType() InvocationType

+ func (x *ChaincodeExec) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeExec) Reset()

+ func (x *ChaincodeExec) String() string

+ type ChaincodeInput struct

+ Args [][]byte

+ Chaincode *ChaincodeLocator

+ Transient map[string][]byte

+ func (*ChaincodeInput) Descriptor() ([]byte, []int)

+ func (*ChaincodeInput) ProtoMessage()

+ func (this *ChaincodeInput) Validate() error

+ func (x *ChaincodeInput) GetArgs() [][]byte

+ func (x *ChaincodeInput) GetChaincode() *ChaincodeLocator

+ func (x *ChaincodeInput) GetTransient() map[string][]byte

+ func (x *ChaincodeInput) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeInput) Reset()

+ func (x *ChaincodeInput) String() string

+ type ChaincodeInstanceEventService struct

+ EventService *ChaincodeEventService

+ Locator *ChaincodeLocator

+ func NewChaincodeInstanceEventService(delivery EventDelivery, channel, chaincode string) *ChaincodeInstanceEventService

+ func (ces *ChaincodeInstanceEventService) Events(request *ChaincodeInstanceEventsRequest, ...) error

+ func (ces *ChaincodeInstanceEventService) ServiceDef() ServiceDef

+ type ChaincodeInstanceEventsRequest struct

+ Block *BlockRange

+ func (*ChaincodeInstanceEventsRequest) Descriptor() ([]byte, []int)

+ func (*ChaincodeInstanceEventsRequest) ProtoMessage()

+ func (this *ChaincodeInstanceEventsRequest) Validate() error

+ func (x *ChaincodeInstanceEventsRequest) GetBlock() *BlockRange

+ func (x *ChaincodeInstanceEventsRequest) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeInstanceEventsRequest) Reset()

+ func (x *ChaincodeInstanceEventsRequest) String() string

+ type ChaincodeInstanceEventsServiceClient interface

+ Events func(ctx context.Context, in *ChaincodeInstanceEventsRequest, ...) (ChaincodeInstanceEventsService_EventsClient, error)

+ func NewChaincodeInstanceEventsServiceClient(cc grpc.ClientConnInterface) ChaincodeInstanceEventsServiceClient

+ type ChaincodeInstanceEventsServiceServer interface

+ Events func(*ChaincodeInstanceEventsRequest, ChaincodeInstanceEventsService_EventsServer) error

+ type ChaincodeInstanceEventsService_EventsClient interface

+ Recv func() (*peer.ChaincodeEvent, error)

+ type ChaincodeInstanceEventsService_EventsServer interface

+ Send func(*peer.ChaincodeEvent) error

+ type ChaincodeInstanceExec struct

+ Input *ChaincodeInstanceInput

+ Type InvocationType

+ func (*ChaincodeInstanceExec) Descriptor() ([]byte, []int)

+ func (*ChaincodeInstanceExec) ProtoMessage()

+ func (this *ChaincodeInstanceExec) Validate() error

+ func (x *ChaincodeInstanceExec) GetInput() *ChaincodeInstanceInput

+ func (x *ChaincodeInstanceExec) GetType() InvocationType

+ func (x *ChaincodeInstanceExec) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeInstanceExec) Reset()

+ func (x *ChaincodeInstanceExec) String() string

+ type ChaincodeInstanceInput struct

+ Args [][]byte

+ Transient map[string][]byte

+ func (*ChaincodeInstanceInput) Descriptor() ([]byte, []int)

+ func (*ChaincodeInstanceInput) ProtoMessage()

+ func (this *ChaincodeInstanceInput) Validate() error

+ func (x *ChaincodeInstanceInput) GetArgs() [][]byte

+ func (x *ChaincodeInstanceInput) GetTransient() map[string][]byte

+ func (x *ChaincodeInstanceInput) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeInstanceInput) Reset()

+ func (x *ChaincodeInstanceInput) String() string

+ type ChaincodeInstanceService struct

+ ChaincodeService *ChaincodeService

+ Locator *ChaincodeLocator

+ func NewChaincodeInstanceService(peer Peer, channel, chaincode string) *ChaincodeInstanceService

+ func (cis *ChaincodeInstanceService) EventService() *ChaincodeInstanceEventService

+ func (cis *ChaincodeInstanceService) Events(request *ChaincodeInstanceEventsRequest, ...) error

+ func (cis *ChaincodeInstanceService) Exec(ctx context.Context, exec *ChaincodeInstanceExec) (*peer.Response, error)

+ func (cis *ChaincodeInstanceService) Invoke(ctx context.Context, input *ChaincodeInstanceInput) (*peer.Response, error)

+ func (cis *ChaincodeInstanceService) Query(ctx context.Context, input *ChaincodeInstanceInput) (*peer.Response, error)

+ func (cis *ChaincodeInstanceService) ServiceDef() ServiceDef

+ type ChaincodeInstanceServiceClient interface

+ Events func(ctx context.Context, in *ChaincodeInstanceEventsRequest, ...) (ChaincodeInstanceService_EventsClient, error)

+ Exec func(ctx context.Context, in *ChaincodeInstanceExec, opts ...grpc.CallOption) (*peer.Response, error)

+ Invoke func(ctx context.Context, in *ChaincodeInstanceInput, opts ...grpc.CallOption) (*peer.Response, error)

+ Query func(ctx context.Context, in *ChaincodeInstanceInput, opts ...grpc.CallOption) (*peer.Response, error)

+ func NewChaincodeInstanceServiceClient(cc grpc.ClientConnInterface) ChaincodeInstanceServiceClient

+ type ChaincodeInstanceServiceServer interface

+ Events func(*ChaincodeInstanceEventsRequest, ChaincodeInstanceService_EventsServer) error

+ Exec func(context.Context, *ChaincodeInstanceExec) (*peer.Response, error)

+ Invoke func(context.Context, *ChaincodeInstanceInput) (*peer.Response, error)

+ Query func(context.Context, *ChaincodeInstanceInput) (*peer.Response, error)

+ type ChaincodeInstanceService_EventsClient interface

+ Recv func() (*peer.ChaincodeEvent, error)

+ type ChaincodeInstanceService_EventsServer interface

+ Send func(*peer.ChaincodeEvent) error

+ type ChaincodeInvoker interface

+ Invoke func(ctx context.Context, chanName string, ccName string, args [][]byte, ...) (res *peer.Response, chaincodeTx string, err error)

+ type ChaincodeLocator struct

+ Chaincode string

+ Channel string

+ func (*ChaincodeLocator) Descriptor() ([]byte, []int)

+ func (*ChaincodeLocator) ProtoMessage()

+ func (this *ChaincodeLocator) Validate() error

+ func (x *ChaincodeLocator) GetChaincode() string

+ func (x *ChaincodeLocator) GetChannel() string

+ func (x *ChaincodeLocator) ProtoReflect() protoreflect.Message

+ func (x *ChaincodeLocator) Reset()

+ func (x *ChaincodeLocator) String() string

+ type ChaincodeQuerier interface

+ Query func(ctx context.Context, chanName string, ccName string, args [][]byte, ...) (*peer.Response, error)

+ type ChaincodeService struct

+ EventService *ChaincodeEventService

+ Peer Peer

+ func New(peer Peer) *ChaincodeService

+ func NewChaincodeService(peer Peer) *ChaincodeService

+ func (cs *ChaincodeService) Events(in *ChaincodeEventsRequest, stream ChaincodeService_EventsServer) error

+ func (cs *ChaincodeService) Exec(ctx context.Context, in *ChaincodeExec) (*peer.Response, error)

+ func (cs *ChaincodeService) InstanceService(channel, chaincode string) *ChaincodeInstanceService

+ func (cs *ChaincodeService) Invoke(ctx context.Context, in *ChaincodeInput) (*peer.Response, error)

+ func (cs *ChaincodeService) Query(ctx context.Context, in *ChaincodeInput) (*peer.Response, error)

+ func (cs *ChaincodeService) ServiceDef() ServiceDef

+ type ChaincodeServiceClient interface

+ Events func(ctx context.Context, in *ChaincodeEventsRequest, opts ...grpc.CallOption) (ChaincodeService_EventsClient, error)

+ Exec func(ctx context.Context, in *ChaincodeExec, opts ...grpc.CallOption) (*peer.Response, error)

+ Invoke func(ctx context.Context, in *ChaincodeInput, opts ...grpc.CallOption) (*peer.Response, error)

+ Query func(ctx context.Context, in *ChaincodeInput, opts ...grpc.CallOption) (*peer.Response, error)

+ func NewChaincodeServiceClient(cc grpc.ClientConnInterface) ChaincodeServiceClient

+ type ChaincodeServiceServer interface

+ Events func(*ChaincodeEventsRequest, ChaincodeService_EventsServer) error

+ Exec func(context.Context, *ChaincodeExec) (*peer.Response, error)

+ Invoke func(context.Context, *ChaincodeInput) (*peer.Response, error)

+ Query func(context.Context, *ChaincodeInput) (*peer.Response, error)

+ type ChaincodeService_EventsClient interface

+ Recv func() (*peer.ChaincodeEvent, error)

+ type ChaincodeService_EventsServer interface

+ Send func(*peer.ChaincodeEvent) error

+ type EventDelivery interface

+ Events func(ctx context.Context, channelName string, ccName string, ...) (chan *peer.ChaincodeEvent, error)

+ type InvocationType int32

+ const InvocationType_INVOKE

+ const InvocationType_QUERY

+ func (InvocationType) Descriptor() protoreflect.EnumDescriptor

+ func (InvocationType) EnumDescriptor() ([]byte, []int)

+ func (InvocationType) Type() protoreflect.EnumType

+ func (x InvocationType) Enum() *InvocationType

+ func (x InvocationType) Number() protoreflect.EnumNumber

+ func (x InvocationType) String() string

+ type Peer interface

+ type PeerReader interface

+ type UnimplementedChaincodeEventsServiceServer struct

+ func (*UnimplementedChaincodeEventsServiceServer) Events(*ChaincodeEventsRequest, ChaincodeEventsService_EventsServer) error

+ type UnimplementedChaincodeInstanceEventsServiceServer struct

+ func (*UnimplementedChaincodeInstanceEventsServiceServer) Events(*ChaincodeInstanceEventsRequest, ChaincodeInstanceEventsService_EventsServer) error

+ type UnimplementedChaincodeInstanceServiceServer struct

+ func (*UnimplementedChaincodeInstanceServiceServer) Events(*ChaincodeInstanceEventsRequest, ChaincodeInstanceService_EventsServer) error

+ func (*UnimplementedChaincodeInstanceServiceServer) Exec(context.Context, *ChaincodeInstanceExec) (*peer.Response, error)

+ func (*UnimplementedChaincodeInstanceServiceServer) Invoke(context.Context, *ChaincodeInstanceInput) (*peer.Response, error)

+ func (*UnimplementedChaincodeInstanceServiceServer) Query(context.Context, *ChaincodeInstanceInput) (*peer.Response, error)

+ type UnimplementedChaincodeServiceServer struct

+ func (*UnimplementedChaincodeServiceServer) Events(*ChaincodeEventsRequest, ChaincodeService_EventsServer) error

+ func (*UnimplementedChaincodeServiceServer) Exec(context.Context, *ChaincodeExec) (*peer.Response, error)

+ func (*UnimplementedChaincodeServiceServer) Invoke(context.Context, *ChaincodeInput) (*peer.Response, error)

+ func (*UnimplementedChaincodeServiceServer) Query(context.Context, *ChaincodeInput) (*peer.Response, error)

May 14, 2020

Changes in this version

type Opt

+ func WithDefaultDoOpts(defaultDoOpts ...api.DoOption) Opt

Jul 1, 2019

Changes in this version

+ func NewChaincodeClient(channelName, chaincodeName string, opts ...Opt) *chaincodeClient

+ type ChaincodeClient interface

+ Query func(stub shim.ChaincodeStubInterface, fn string, args []interface{}, ...) (interface{}, error)

+ type ClientOpt func(*chaincodeClient)

May 29, 2019

Changes in this version

+ const CtxTransientKey

+ var ErrEventChannelClosed = errors.New(`event channel is closed`)

+ func ContextWithTransientMap(ctx context.Context, transient map[string][]byte) context.Context

+ func ContextWithTransientValue(ctx context.Context, key string, value []byte) context.Context

+ func NewChaincode(service service.Chaincode, channelName, chaincodeName string, opts ...Opt) *chaincode

+ func TransientFromContext(ctx context.Context) (map[string][]byte, error)

+ type Action string

+ const Invoke

+ const Query

+ type Chaincode interface

+ Events func(ctx context.Context) (ChaincodeEventSub, error)

+ Invoke func(ctx context.Context, fn string, args []interface{}, target interface{}) (interface{}, error)

+ Query func(ctx context.Context, fn string, args []interface{}, target interface{}) (interface{}, error)

+ type ChaincodeEventServerStream struct

+ func NewChaincodeEventServerStream(ctx context.Context, opts ...EventOpt) (stream *ChaincodeEventServerStream)

+ func (*ChaincodeEventServerStream) SendHeader(metadata.MD) error

+ func (*ChaincodeEventServerStream) SetHeader(metadata.MD) error

+ func (*ChaincodeEventServerStream) SetTrailer(metadata.MD)

+ func (s *ChaincodeEventServerStream) Close()

+ func (s *ChaincodeEventServerStream) Context() context.Context

+ func (s *ChaincodeEventServerStream) Events() <-chan *peer.ChaincodeEvent

+ func (s *ChaincodeEventServerStream) Recv(e *peer.ChaincodeEvent) error

+ func (s *ChaincodeEventServerStream) RecvMsg(m interface{}) error

+ func (s *ChaincodeEventServerStream) SendMsg(m interface{}) (err error)

+ type ChaincodeEventSub interface

+ Close func()

+ Context func() context.Context

+ Events func() <-chan *peer.ChaincodeEvent

+ Recv func(*peer.ChaincodeEvent) error

+ type ContextOpt func(ctx context.Context) context.Context

+ type EventOpt func(event *peer.ChaincodeEvent) error

+ type InputOpt func(action Action, input *service.ChaincodeInput) error

+ type Opt func(*chaincode)

+ func WithArgsEncryption(encKey []byte) Opt

+ func WithDefaultSigner(defaultSigner msp.SigningIdentity) Opt

+ func WithEncryption(encKey []byte) Opt

+ func WithEventDecryption(encKey []byte) Opt

+ func WithInvokePayloadDecryption(encKey []byte) Opt

+ func WithTransientValue(key string, value []byte) Opt

+ type OutputOpt func(action Action, response *peer.Response) error

+ type RegisterHandlerFromEndpoint func(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ type ServiceDef struct

+ Desc *grpc.ServiceDesc

+ HandlerFromEndpointRegister RegisterHandlerFromEndpoint

+ Service interface{}