utils

func ConvertAnyToInterface ¶

func ConvertAnyToInterface(anyValue *anypb.Any) (interface{}, error)

func ConvertInterfaceToAny ¶

func ConvertInterfaceToAny(v interface{}) (*anypb.Any, error)

func DeexpandTilde ¶

func DeexpandTilde(path string) string

DeexpandTilde takes a path and if it is in the home directory, it will replace it with a ~.

func ExpandTilde ¶

func ExpandTilde(path string) (string, error)

ExpandTilde takes a path and if it starts with a ~, it will replace it with the home directory.

func GetPluginStorePath ¶

func GetPluginStorePath(pluginID string) (string, error)

GetPluginStorePath returns the path to the plugin store for the given plugin.

func GetStore ¶

func GetStore(capability, pluginID string) (*os.File, error)

getStore returns a file handle to the store for the given plugin and capability. If the store does not exist, it will be created. Make sure to close the file handle after using it!

func InitializePluginStore ¶

func InitializePluginStore(pluginID string) error

initializeStore creates the store directory for the given plugin and capability.

func NewServerInterceptors ¶

func NewServerInterceptors() ([]grpc.UnaryServerInterceptor, []grpc.StreamServerInterceptor)

NewServerInterceptors returns the default unary and stream interceptor chains for the plugin SDK gRPC server.

func RegisterServerOpts ¶

func RegisterServerOpts(opts []grpc.ServerOption) []grpc.ServerOption

RegisterServerOpts returns a list of gRPC server options with the necessary interceptors for the plugin SDK.

func RemoveStore ¶

func RemoveStore(capability, pluginID string) error

removeStore removes the store for the given plugin and capability.