grpc

type API interface {
	io.Closer

	// DaprInternal Service methods
	internalv1pb.ServiceInvocationServer

	// Dapr Service methods
	runtimev1pb.DaprServer
}

type APIOpts struct {
	Universal             *universal.Universal
	Logger                logger.Logger
	Channels              *channels.Channels
	PubSubAdapter         runtimePubsub.Adapter
	PubSubAdapterStreamer runtimePubsub.AdapterStreamer
	Outbox                outbox.Outbox
	DirectMessaging       invokev1.DirectMessaging
	SendToOutputBindingFn func(ctx context.Context, name string, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)
	TracingSpec           config.TracingSpec
	AccessControlList     *config.AccessControlList
	Processor             *processor.Processor
}

type Options struct {
	API            API
	Config         ServerConfig
	TracingSpec    config.TracingSpec
	MetricSpec     config.MetricSpec
	APISpec        config.APISpec
	Proxy          messaging.Proxy
	WorkflowEngine wfengine.Interface
	Healthz        healthz.Healthz
}

type OptionsInternal struct {
	API         API
	Config      ServerConfig
	TracingSpec config.TracingSpec
	MetricSpec  config.MetricSpec
	Security    security.Handler
	Proxy       messaging.Proxy
	Healthz     healthz.Healthz
}

type Server interface {
	io.Closer
	StartNonBlocking() error
}

type ServerConfig struct {
	AppID              string
	HostAddress        string
	Port               int
	APIListenAddresses []string
	NameSpace          string
	TrustDomain        string
	MaxRequestBodySize int // In bytes
	ReadBufferSize     int // In bytes
	UnixDomainSocket   string
	EnableAPILogging   bool
}