package benchmark_grpc

Import Path
	github.com/pancsta/asyncmachine-go/examples/benchmark_grpc (on go.dev)

Dependency Relation
	imports 12 packages, and imported by 0 packages

Involved Source Files

	    server_arpc.go
	    server_grpc.go
	    worker.go
Package-Level Type Names (total 5)

	/* sort by: alphabet | popularity */
	 type Op int (basic type)

		As Inputs Of (at least one exported)
			func (*Worker).CallOp(op Op)
		As Types Of (total 3)
			const Op1
			const Op2
			const Op3

	 type Value int (basic type)

		As Outputs Of (at least one exported)
			func (*Worker).GetValue() Value
		As Types Of (total 3)
			const Value1
			const Value2
			const Value3

	 type Worker (struct)

		Fields (total 2)
			ErrCount int
			SuccessCount int
		Methods (total 4)
			(*Worker) CallOp(op Op)
			(*Worker) GetValue() Value
			(*Worker) Start()
			(*Worker) Subscribe(lis func())
		As Inputs Of (at least 2)
			func NewWorkerArpcServer(ctx context.Context, addr string, worker *Worker) (*WorkerArpcServer, error)
			func NewWorkerServiceServer(worker *Worker) *WorkerServiceServer

	 type WorkerArpcServer (struct)

		Fields (total 3)
			Mach *am.Machine
			RPC *arpc.Server
			Worker *Worker
		Methods (total 4)
			(*WorkerArpcServer) CallOpEnter(e *am.Event) bool
			(*WorkerArpcServer) CallOpState(e *am.Event)
			(*WorkerArpcServer) EventState(_ *am.Event)
			(*WorkerArpcServer) StartState(_ *am.Event)
		As Outputs Of (at least one exported)
			func NewWorkerArpcServer(ctx context.Context, addr string, worker *Worker) (*WorkerArpcServer, error)

	 type WorkerServiceServer (struct)

		Fields (only one)
			UnimplementedWorkerServiceServer pb.UnimplementedWorkerServiceServer
		Methods (total 4)
			(*WorkerServiceServer) CallOp(ctx context.Context, req *pb.CallOpRequest) (*pb.CallOpResponse, error)
			(*WorkerServiceServer) GetValue(ctx context.Context, req *pb.Empty) (*pb.GetValueResponse, error)
			(*WorkerServiceServer) Start(ctx context.Context, req *pb.Empty) (*pb.Empty, error)
			(*WorkerServiceServer) Subscribe(req *pb.Empty, stream pb.WorkerService_SubscribeServer) error
		Implements (at least 2)
			 WorkerServiceServer : github.com/pancsta/asyncmachine-go/examples/benchmark_grpc/proto.UnsafeWorkerServiceServer
			*WorkerServiceServer : github.com/pancsta/asyncmachine-go/examples/benchmark_grpc/proto.WorkerServiceServer
		As Outputs Of (at least one exported)
			func NewWorkerServiceServer(worker *Worker) *WorkerServiceServer


Package-Level Functions (total 2)

	 func NewWorkerArpcServer(ctx context.Context, addr string, worker *Worker) (*WorkerArpcServer, error)
	 func NewWorkerServiceServer(worker *Worker) *WorkerServiceServer
Package-Level Constants (total 6)

	const Op1 Op = 1
	const Op2 Op = 2
	const Op3 Op = 3
	const Value1 Value = 1
	const Value2 Value = 2
	const Value3 Value = 3

The pages are generated with Golds v0.8.2. (GOOS=linux GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds.