test

Documentation

Index

• Variables
• type FunctionalTestActorTypedProvider
  • func (f FunctionalTestActorTypedProvider) Provide() vivid.Actor
• type Request
  • func (*Request) Descriptor() ([]byte, []int)
  • func (x *Request) GetMessage() string
  • func (*Request) ProtoMessage()
  • func (x *Request) ProtoReflect() protoreflect.Message
  • func (x *Request) Reset()
  • func (x *Request) String() string
• type Response
  • func (*Response) Descriptor() ([]byte, []int)
  • func (x *Response) GetMessage() string
  • func (*Response) ProtoMessage()
  • func (x *Response) ProtoReflect() protoreflect.Message
  • func (x *Response) Reset()
  • func (x *Response) String() string
• type TestActorTyped
• type TestActorTypedInterface
• type TestActorTypedProvider
• type TestActorTypedRef
  • func NewTestActorTyped(ref vivid.ActorRef) *TestActorTypedRef
  • func (t *TestActorTypedRef) Call(sender vivid.ActorContext, message *Request)
  • func (t *TestActorTypedRef) Ping(sender vivid.ActorContext, message *Request) (*Response, error)
  • func (t *TestActorTypedRef) Say(sender vivid.ActorContext, message *Request)

Variables

var File_typed_test_proto protoreflect.FileDescriptor

Types

type FunctionalTestActorTypedProvider

type FunctionalTestActorTypedProvider func() TestActorTypedInterface

func (FunctionalTestActorTypedProvider) Provide

func (f FunctionalTestActorTypedProvider) Provide() vivid.Actor

type Request

type Request struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor

func (*Request) Descriptor() ([]byte, []int)

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetMessage

func (x *Request) GetMessage() string

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) ProtoReflect

func (x *Request) ProtoReflect() protoreflect.Message

func (*Request) Reset

func (x *Request) Reset()

func (*Request) String

func (x *Request) String() string

type Response

type Response struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetMessage

func (x *Response) GetMessage() string

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) ProtoReflect

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset

func (x *Response) Reset()

func (*Response) String

func (x *Response) String() string

type TestActorTyped

type TestActorTyped interface {
	vivid.Actor
	TestActorTypedInterface
}

type TestActorTypedInterface

type TestActorTypedInterface interface {

	// Say 是一个 Tell 类型的方法，它将会非阻塞的将消息投递到目标邮箱。
	Say(ctx vivid.ActorContext, message *Request)

	// Call 是一个 Ask 类型的方法，它将会非阻塞的将消息投递到目标邮箱，但是不一定能收到返回的结果。
	Call(ctx vivid.ActorContext, message *Request, responder tm.AskResponder[*Response])

	// Ping 是一个 FutureAsk 类型的方法，它将会阻塞的将消息投递到目标邮箱，并且会等待返回结果。
	//  - 超时时间为 1000 毫秒
	Ping(ctx vivid.ActorContext, message *Request) (*Response, error)
}

type TestActorTypedProvider

type TestActorTypedProvider interface {
	vivid.ActorProvider
}

type TestActorTypedRef

type TestActorTypedRef struct {
	// contains filtered or unexported fields
}

func NewTestActorTyped

func NewTestActorTyped(ref vivid.ActorRef) *TestActorTypedRef

func (*TestActorTypedRef) Call

func (t *TestActorTypedRef) Call(sender vivid.ActorContext, message *Request)

func (*TestActorTypedRef) Ping

func (t *TestActorTypedRef) Ping(sender vivid.ActorContext, message *Request) (*Response, error)

func (*TestActorTypedRef) Say

func (t *TestActorTypedRef) Say(sender vivid.ActorContext, message *Request)